diff options
author | seanm <sean.mcnamara@webtrends.com> | 2013-05-10 15:54:26 -0600 |
---|---|---|
committer | seanm <sean.mcnamara@webtrends.com> | 2013-05-10 15:54:26 -0600 |
commit | 3632980b1b61dbb9ab9a3ab3d92fb415cb7173b9 (patch) | |
tree | 93739e4b33d3aa7ae51a34c83630a7b91658caf2 /streaming | |
parent | d761e7359deb7ca864d33b8f2e4380b57448630b (diff) | |
download | spark-3632980b1b61dbb9ab9a3ab3d92fb415cb7173b9.tar.gz spark-3632980b1b61dbb9ab9a3ab3d92fb415cb7173b9.tar.bz2 spark-3632980b1b61dbb9ab9a3ab3d92fb415cb7173b9.zip |
fixing indentation
Diffstat (limited to 'streaming')
-rw-r--r-- | streaming/src/main/scala/spark/streaming/api/java/JavaStreamingContext.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/streaming/src/main/scala/spark/streaming/api/java/JavaStreamingContext.scala b/streaming/src/main/scala/spark/streaming/api/java/JavaStreamingContext.scala index 13427873ff..4ad2bdf8a8 100644 --- a/streaming/src/main/scala/spark/streaming/api/java/JavaStreamingContext.scala +++ b/streaming/src/main/scala/spark/streaming/api/java/JavaStreamingContext.scala @@ -105,7 +105,7 @@ class JavaStreamingContext(val ssc: StreamingContext) { * @param storageLevel RDD storage level. Defaults to memory-only */ def kafkaStream[T, D <: kafka.serializer.Decoder[_]: Manifest]( - kafkaParams: JMap[String, String], + kafkaParams: JMap[String, String], topics: JMap[String, JInt], storageLevel: StorageLevel) : JavaDStream[T] = { |