[jira] [Updated] (HBASE-16804) JavaHBaseContext.streamBulkGet is void but must be JavaDStream

2016-10-10 Thread Ted Yu (JIRA) 

 [ 
https://issues.apache.org/jira/browse/HBASE-16804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ted Yu updated HBASE-16804:
---
Status: Patch Available  (was: Open)

> 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
>  Labels: beginner, spark
> 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
(v6.3.4#6332)

[jira] [Updated] (HBASE-16804) JavaHBaseContext.streamBulkGet is void but must be JavaDStream

2016-10-10 Thread Igor Yurinok (JIRA) 

 [ 
https://issues.apache.org/jira/browse/HBASE-16804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Igor Yurinok updated HBASE-16804:
-
Attachment: HBASE-16804.patch

> 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
>  Labels: beginner, spark
> 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
(v6.3.4#6332)

[jira] [Updated] (HBASE-16804) JavaHBaseContext.streamBulkGet is void but must be JavaDStream

2016-10-10 Thread Igor Yurinok (JIRA) 

 [ 
https://issues.apache.org/jira/browse/HBASE-16804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Igor Yurinok updated HBASE-16804:
-
Labels: beginner spark  (was: )

> 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
>  Labels: beginner, spark
>
> 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)