org.apache.flink.connectors.hive

类 HiveTableSink

java.lang.Object

org.apache.flink.table.sinks.OutputFormatTableSink<org.apache.flink.types.Row>

org.apache.flink.connectors.hive.HiveTableSink

所有已实现的接口:

org.apache.flink.table.sinks.OverwritableTableSink, org.apache.flink.table.sinks.PartitionableTableSink, org.apache.flink.table.sinks.StreamTableSink<org.apache.flink.types.Row>, org.apache.flink.table.sinks.TableSink<org.apache.flink.types.Row>

public class HiveTableSink
extends org.apache.flink.table.sinks.OutputFormatTableSink<org.apache.flink.types.Row>
implements org.apache.flink.table.sinks.PartitionableTableSink, org.apache.flink.table.sinks.OverwritableTableSink

Table sink to write to Hive tables.

构造器概要

构造器

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

方法概要

限定符和类型	方法和说明
org.apache.flink.table.sinks.TableSink<org.apache.flink.types.Row>	configure(String[] fieldNames, org.apache.flink.api.common.typeinfo.TypeInformation<?>[] fieldTypes)
boolean	configurePartitionGrouping(boolean supportsGrouping)
org.apache.flink.table.types.DataType	getConsumedDataType()
org.apache.flink.api.common.io.OutputFormat<org.apache.flink.types.Row>	getOutputFormat()
org.apache.flink.table.api.TableSchema	getTableSchema()
void	setOverwrite(boolean overwrite)
void	setStaticPartition(Map<String,String> partitionSpec)

从类继承的方法 org.apache.flink.table.sinks.OutputFormatTableSink

consumeDataStream, emitDataStream

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

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

从接口继承的方法 org.apache.flink.table.sinks.TableSink

getFieldNames, getFieldTypes, getOutputType

构造器详细资料

HiveTableSink

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

方法详细资料

getOutputFormat

public org.apache.flink.api.common.io.OutputFormat<org.apache.flink.types.Row> getOutputFormat()

指定者:

getOutputFormat 在类中 org.apache.flink.table.sinks.OutputFormatTableSink<org.apache.flink.types.Row>

configure

public org.apache.flink.table.sinks.TableSink<org.apache.flink.types.Row> configure(String[] fieldNames,
                                                                                    org.apache.flink.api.common.typeinfo.TypeInformation<?>[] fieldTypes)

指定者:

configure 在接口中 org.apache.flink.table.sinks.TableSink<org.apache.flink.types.Row>

getConsumedDataType

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

指定者:

getConsumedDataType 在接口中 org.apache.flink.table.sinks.TableSink<org.apache.flink.types.Row>

getTableSchema

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

指定者:

getTableSchema 在接口中 org.apache.flink.table.sinks.TableSink<org.apache.flink.types.Row>

configurePartitionGrouping

public boolean configurePartitionGrouping(boolean supportsGrouping)

指定者:

configurePartitionGrouping 在接口中 org.apache.flink.table.sinks.PartitionableTableSink

setStaticPartition

public void setStaticPartition(Map<String,String> partitionSpec)

指定者:

setStaticPartition 在接口中 org.apache.flink.table.sinks.PartitionableTableSink

setOverwrite

public void setOverwrite(boolean overwrite)

指定者:

setOverwrite 在接口中 org.apache.flink.table.sinks.OverwritableTableSink