fixing indentation

2013-05-10 15:54:26 -06:00 · 2013-05-10 15:54:26 -06:00 · 3632980b1b
parent d761e7359d
commit 3632980b1b
1 changed files with 1 additions and 1 deletions
--- 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] = {