[
https://issues.apache.org/jira/browse/HBASE-16804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Balazs Meszaros updated HBASE-16804:
------------------------------------
Fix Version/s: connector-1.0.0
Component/s: hbase-connectors
> JavaHBaseContext.streamBulkGet is void but should be JavaDStream
> -----------------------------------------------------------------
>
> Key: HBASE-16804
> URL: https://issues.apache.org/jira/browse/HBASE-16804
> Project: HBase
> Issue Type: Bug
> Components: hbase-connectors, spark
> Affects Versions: 2.0.0
> Reporter: Igor Yurinok
> Assignee: Igor Yurinok
> Priority: Major
> Labels: beginner, spark
> Fix For: 3.0.0, connector-1.0.0
>
> Attachments: HBASE-16804.patch
>
>
> 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
(v7.6.3#76005)
