Index: hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/JavaHBaseContext.scala IDEA additional info: Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP <+>UTF-8 =================================================================== --- hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/JavaHBaseContext.scala (revision 7493e79f15e0a1217dc50ca4431d6ded07df479f) +++ hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/JavaHBaseContext.scala (revision ) @@ -281,7 +281,7 @@ batchSize: Integer, javaDStream: JavaDStream[T], makeGet: Function[T, Get], - convertResult: Function[Result, U]) { + convertResult: Function[Result, U]): JavaDStream[U] = { JavaDStream.fromDStream(hbaseContext.streamBulkGet(tableName, batchSize, javaDStream.dstream,