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] = { |