[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15818486#comment-15818486
]
ramkrishna.s.vasudevan commented on FLINK-2168:
-----------------------------------------------
One suggestion is that, though we are going to issue a scan (batch read) or get
(random read) it is better we specify the family and qualifier to be used in
that read. Otherwise we end up returning more results and on the result we need
to filter out the fieldNAmes that were passed. Assuming that the fiedNames are
unique and there are no same colNames in two different families.
For creating the DataSet, need to create some input format that implements
ResultTypeQueryable? Am I right? And that is where the conversion of the byte[]
result to the TypeInfo specified happens I believe.
> Add HBaseTableSource
> --------------------
>
> Key: FLINK-2168
> URL: https://issues.apache.org/jira/browse/FLINK-2168
> Project: Flink
> Issue Type: New Feature
> Components: Table API & SQL
> Affects Versions: 0.9
> Reporter: Fabian Hueske
> Assignee: ramkrishna.s.vasudevan
> Priority: Minor
> Labels: starter
>
> Add a {{HBaseTableSource}} to read data from a HBase table. The
> {{HBaseTableSource}} should implement the {{ProjectableTableSource}}
> (FLINK-3848) and {{FilterableTableSource}} (FLINK-3849) interfaces.
> The implementation can be based on Flink's {{TableInputFormat}}.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
