flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-2168) Add HBaseTableSource
Date Wed, 01 Feb 2017 06:21:52 GMT

    [ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15848060#comment-15848060
] 

ASF GitHub Bot commented on FLINK-2168:
---------------------------------------

Github user ramkrish86 commented on the issue:

    https://github.com/apache/flink/pull/3149
  
    Just a general question
    `def projectFields(fields: Array[Int]): ProjectableTableSource[T]`
    
    Is it mandatory to only have int[] here. Can we have String[] that allows to specify specific
names? May be even more generic could be to have a ColumnarTableProjectableSource which allows
to specify family to column mapping some way? Ultimately its the table source that is going
to do the mapping and create the projected table source. So that should be fine?


> 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.15#6346)

Mime
View raw message