diff --git a/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/JavaHBaseContext.scala b/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/JavaHBaseContext.scala
index 7deb5b8334a..a99e0e3af44 100644
--- a/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/JavaHBaseContext.scala
+++ b/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/JavaHBaseContext.scala
@@ -281,7 +281,7 @@ class JavaHBaseContext(@transient jsc: JavaSparkContext,
                           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,