public class HBaseTableSource extends Object implements org.apache.flink.table.sources.BatchTableSource<Row>, org.apache.flink.table.sources.ProjectableTableSource<Row>
The table name and required HBase configuration is passed during HBaseTableSource
construction.
Use addColumn(String, String, Class)
to specify the family, qualifier, and type of columns to scan.
The TableSource returns Row
with nested Rows for each column family.
The HBaseTableSource is used as shown in the example below.
HBaseTableSource hSrc = new HBaseTableSource(conf, "hTable");
hSrc.addColumn("fam1", "col1", byte[].class);
hSrc.addColumn("fam1", "col2", Integer.class);
hSrc.addColumn("fam2", "col1", String.class);
tableEnv.registerTableSource("hTable", hSrc);
Table res = tableEnv.sql("SELECT t.fam2.col1, SUM(t.fam1.col2) FROM hTable AS t GROUP BY t.fam2.col1");
Constructor and Description |
---|
HBaseTableSource(Configuration conf,
String tableName)
The HBase configuration and the name of the table to read.
|
Modifier and Type | Method and Description |
---|---|
void |
addColumn(String family,
String qualifier,
Class<?> clazz)
Adds a column defined by family, qualifier, and type to the table schema.
|
String |
explainSource() |
DataSet<Row> |
getDataSet(ExecutionEnvironment execEnv) |
TypeInformation<Row> |
getReturnType() |
org.apache.flink.table.api.TableSchema |
getTableSchema() |
HBaseTableSource |
projectFields(int[] fields) |
void |
setCharset(String charset)
Specifies the charset to parse Strings to HBase byte[] keys and String values.
|
public HBaseTableSource(Configuration conf, String tableName)
conf
- hbase configurationtableName
- the tableNamepublic void addColumn(String family, String qualifier, Class<?> clazz)
family
- the family namequalifier
- the qualifier nameclazz
- the data type of the qualifierpublic void setCharset(String charset)
charset
- Name of the charset to use.public TypeInformation<Row> getReturnType()
getReturnType
in interface org.apache.flink.table.sources.TableSource<Row>
public org.apache.flink.table.api.TableSchema getTableSchema()
getTableSchema
in interface org.apache.flink.table.sources.TableSource<Row>
public DataSet<Row> getDataSet(ExecutionEnvironment execEnv)
getDataSet
in interface org.apache.flink.table.sources.BatchTableSource<Row>
public HBaseTableSource projectFields(int[] fields)
projectFields
in interface org.apache.flink.table.sources.ProjectableTableSource<Row>
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.