From 83fc59d5c98e4847eda01d08510cd3c0ee9cfa05 Mon Sep 17 00:00:00 2001
From: tedyu <yuzhihong@gmail.com>
Date: Mon, 10 Oct 2016 19:34:21 -0700
Subject: [PATCH] HBASE-16804 JavaHBaseContext.streamBulkGet is void but should
 be JavaDStream (Igor Yurinok)

---
 .../scala/org/apache/hadoop/hbase/spark/JavaHBaseContext.scala  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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,