Repository: hbase Updated Branches: refs/heads/master 0f21c41ed -> 83fc59d5c
HBASE-16804 JavaHBaseContext.streamBulkGet is void but should be JavaDStream (Igor Yurinok) Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/83fc59d5 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/83fc59d5 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/83fc59d5 Branch: refs/heads/master Commit: 83fc59d5c98e4847eda01d08510cd3c0ee9cfa05 Parents: 0f21c41 Author: tedyu <yuzhih...@gmail.com> Authored: Mon Oct 10 19:34:21 2016 -0700 Committer: tedyu <yuzhih...@gmail.com> Committed: Mon Oct 10 19:34:21 2016 -0700 ---------------------------------------------------------------------- .../scala/org/apache/hadoop/hbase/spark/JavaHBaseContext.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/83fc59d5/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/JavaHBaseContext.scala ---------------------------------------------------------------------- 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 7deb5b8..a99e0e3 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,
