[HBASE-16804] JavaHBaseContext.streamBulkGet is void but should be JavaDStream

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.0.0
• Fix Version/s: 3.0.0-alpha-1, connector-1.0.0
• Component/s: hbase-connectors, spark
• Labels: beginner spark
• Hadoop Flags: Reviewed
• Assignee: Igor Yurinok
• Reporter: Igor Yurinok
• Created: 11/Oct/16 01:09
• Updated: 26/Apr/19 10:14
• Resolved: 11/Oct/16 02:41

Description

This is current implementation in JavaHBaseContext.scala:

def streamBulkGet[T, U](tableName: TableName,
                          batchSize: Integer,
                          javaDStream: JavaDStream[T],
                          makeGet: Function[T, Get],
                          convertResult: Function[Result, U])

Should be:

def streamBulkGet[T, U](tableName: TableName,
                          batchSize: Integer,
                          javaDStream: JavaDStream[T],
                          makeGet: Function[T, Get],
                          convertResult: Function[Result, U]): JavaDStream[U]