Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-16804 JavaHBaseContext.streamBulkGet is void but should be JavaDStream (Igor Yurinok)

This commit is contained in:
tedyu 2016-10-10 19:34:21 -07:00
parent 0f21c41eda
commit 83fc59d5c9
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/JavaHBaseContext.scala
View File

@ -281,7 +281,7 @@ class JavaHBaseContext(@transient jsc: JavaSparkContext,
batchSize: Integer, batchSize: Integer,
javaDStream: JavaDStream[T], javaDStream: JavaDStream[T],
makeGet: Function[T, Get], makeGet: Function[T, Get],
convertResult: Function[Result, U]) { convertResult: Function[Result, U]): JavaDStream[U] = {
JavaDStream.fromDStream(hbaseContext.streamBulkGet(tableName, JavaDStream.fromDStream(hbaseContext.streamBulkGet(tableName,
batchSize, batchSize,
javaDStream.dstream, javaDStream.dstream,