org.apache.flink.connectors.hive

类 HiveTableSource

java.lang.Object

org.apache.flink.connectors.hive.HiveTableSource

所有已实现的接口:

org.apache.flink.table.sources.LimitableTableSource<org.apache.flink.table.dataformat.BaseRow>, org.apache.flink.table.sources.PartitionableTableSource, org.apache.flink.table.sources.ProjectableTableSource<org.apache.flink.table.dataformat.BaseRow>, org.apache.flink.table.sources.StreamTableSource<org.apache.flink.table.dataformat.BaseRow>, org.apache.flink.table.sources.TableSource<org.apache.flink.table.dataformat.BaseRow>

public class HiveTableSource
extends Object
implements org.apache.flink.table.sources.StreamTableSource<org.apache.flink.table.dataformat.BaseRow>, org.apache.flink.table.sources.PartitionableTableSource, org.apache.flink.table.sources.ProjectableTableSource<org.apache.flink.table.dataformat.BaseRow>, org.apache.flink.table.sources.LimitableTableSource<org.apache.flink.table.dataformat.BaseRow>

A TableSource implementation to read data from Hive tables.

构造器概要

构造器

构造器和说明
HiveTableSource(org.apache.hadoop.mapred.JobConf jobConf, org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.CatalogTable catalogTable)

方法概要

限定符和类型	方法和说明
org.apache.flink.table.sources.TableSource<org.apache.flink.table.dataformat.BaseRow>	applyLimit(long limit)
org.apache.flink.table.sources.TableSource<org.apache.flink.table.dataformat.BaseRow>	applyPartitionPruning(List<Map<String,String>> remainingPartitions)
String	explainSource()
org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.dataformat.BaseRow>	getDataStream(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment execEnv)
List<Map<String,String>>	getPartitions()
org.apache.flink.table.types.DataType	getProducedDataType()
org.apache.flink.table.api.TableSchema	getTableSchema()
boolean	isBounded()
boolean	isLimitPushedDown()
org.apache.flink.table.sources.TableSource<org.apache.flink.table.dataformat.BaseRow>	projectFields(int[] fields)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 org.apache.flink.table.sources.TableSource

getReturnType

构造器详细资料

HiveTableSource

public HiveTableSource(org.apache.hadoop.mapred.JobConf jobConf,
                       org.apache.flink.table.catalog.ObjectPath tablePath,
                       org.apache.flink.table.catalog.CatalogTable catalogTable)

方法详细资料

isBounded

public boolean isBounded()

指定者:

isBounded 在接口中 org.apache.flink.table.sources.StreamTableSource<org.apache.flink.table.dataformat.BaseRow>

getDataStream

public org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.dataformat.BaseRow> getDataStream(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment execEnv)

指定者:

getDataStream 在接口中 org.apache.flink.table.sources.StreamTableSource<org.apache.flink.table.dataformat.BaseRow>

getTableSchema

public org.apache.flink.table.api.TableSchema getTableSchema()

指定者:

getTableSchema 在接口中 org.apache.flink.table.sources.TableSource<org.apache.flink.table.dataformat.BaseRow>

getProducedDataType

public org.apache.flink.table.types.DataType getProducedDataType()

指定者:

getProducedDataType 在接口中 org.apache.flink.table.sources.TableSource<org.apache.flink.table.dataformat.BaseRow>

isLimitPushedDown

public boolean isLimitPushedDown()

指定者:

isLimitPushedDown 在接口中 org.apache.flink.table.sources.LimitableTableSource<org.apache.flink.table.dataformat.BaseRow>

applyLimit

public org.apache.flink.table.sources.TableSource<org.apache.flink.table.dataformat.BaseRow> applyLimit(long limit)

指定者:

applyLimit 在接口中 org.apache.flink.table.sources.LimitableTableSource<org.apache.flink.table.dataformat.BaseRow>

getPartitions

public List<Map<String,String>> getPartitions()

指定者:

getPartitions 在接口中 org.apache.flink.table.sources.PartitionableTableSource

applyPartitionPruning

public org.apache.flink.table.sources.TableSource<org.apache.flink.table.dataformat.BaseRow> applyPartitionPruning(List<Map<String,String>> remainingPartitions)

指定者:

applyPartitionPruning 在接口中 org.apache.flink.table.sources.PartitionableTableSource

explainSource

public String explainSource()

指定者:

explainSource 在接口中 org.apache.flink.table.sources.TableSource<org.apache.flink.table.dataformat.BaseRow>

projectFields

public org.apache.flink.table.sources.TableSource<org.apache.flink.table.dataformat.BaseRow> projectFields(int[] fields)

指定者:

projectFields 在接口中 org.apache.flink.table.sources.ProjectableTableSource<org.apache.flink.table.dataformat.BaseRow>