Igor Yurinok created HBASE-16804: ------------------------------------ Summary: JavaHBaseContext.streamBulkGet is void but must be JavaDStream Key: HBASE-16804 URL: https://issues.apache.org/jira/browse/HBASE-16804 Project: HBase Issue Type: Bug Components: spark Affects Versions: 2.0.0 Reporter: Igor Yurinok
This is current implementation in JavaHBaseContext.scala: {code} def streamBulkGet[T, U](tableName: TableName, batchSize: Integer, javaDStream: JavaDStream[T], makeGet: Function[T, Get], convertResult: Function[Result, U]) {code} Should be: {code} def streamBulkGet[T, U](tableName: TableName, batchSize: Integer, javaDStream: JavaDStream[T], makeGet: Function[T, Get], convertResult: Function[Result, U]): JavaDStream[U] {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)