[ https://issues.apache.org/jira/browse/FLINK-5554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15829146#comment-15829146 ]
Jark Wu edited comment on FLINK-5554 at 1/19/17 1:56 AM: --------------------------------------------------------- Flink has already supported composite types , and can access like following: {code} // SQL SELECT composite.name FROM composites // Java Table API tab.select("composite.name") // Scala Table API tab.select('composite.get('name)) {code} I think the HBaseTableSource should return a composite type (with column family and qualifier), and we can get columns by composite type accessing. was (Author: jark): Flink has already supported composite types , and can access like following: {{code}} // SQL SELECT composite.name FROM composites // Java Table API tab.select("composite.name") // Scala Table API tab.select('composite.get('name)) {{code}} I think the HBaseTableSource should return a composite type (with column family and qualifier), and we can get columns by composite type accessing. > Add sql operator to table api for getting columns from HBase > ------------------------------------------------------------ > > Key: FLINK-5554 > URL: https://issues.apache.org/jira/browse/FLINK-5554 > Project: Flink > Issue Type: Improvement > Components: Table API & SQL > Reporter: Anton Solovev > > example of select query > {code} > table.select("f1:q1, f1:q2, f1:q3"); > {code} > or/and > {code} > table.select('f1:'q1, 'f1:'q2, 'f1:'q3); > {code} > let's discuss how to provide better api for selecting from HBase -- This message was sent by Atlassian JIRA (v6.3.4#6332)