org.apache.flink.connectors.hive

类 HiveTableSink

java.lang.Object

org.apache.flink.connectors.hive.HiveTableSink

所有已实现的接口:

org.apache.flink.table.sinks.AppendStreamTableSink, org.apache.flink.table.sinks.OverwritableTableSink, org.apache.flink.table.sinks.PartitionableTableSink, org.apache.flink.table.sinks.StreamTableSink, org.apache.flink.table.sinks.TableSink

public class HiveTableSink
extends Object
implements org.apache.flink.table.sinks.AppendStreamTableSink, org.apache.flink.table.sinks.PartitionableTableSink, org.apache.flink.table.sinks.OverwritableTableSink

Table sink to write to Hive tables.

构造器概要

构造器

构造器和说明
HiveTableSink(boolean userMrWriter, boolean isBounded, org.apache.hadoop.mapred.JobConf jobConf, org.apache.flink.table.catalog.ObjectIdentifier identifier, org.apache.flink.table.catalog.CatalogTable table)

方法概要

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

从类继承的方法 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(boolean userMrWriter,
                     boolean isBounded,
                     org.apache.hadoop.mapred.JobConf jobConf,
                     org.apache.flink.table.catalog.ObjectIdentifier identifier,
                     org.apache.flink.table.catalog.CatalogTable table)

方法详细资料

consumeDataStream

public final org.apache.flink.streaming.api.datastream.DataStreamSink consumeDataStream(org.apache.flink.streaming.api.datastream.DataStream dataStream)

指定者:

consumeDataStream 在接口中 org.apache.flink.table.sinks.StreamTableSink

getConsumedDataType

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

指定者:

getConsumedDataType 在接口中 org.apache.flink.table.sinks.TableSink

getTableSchema

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

指定者:

getTableSchema 在接口中 org.apache.flink.table.sinks.TableSink

configure

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

指定者:

configure 在接口中 org.apache.flink.table.sinks.TableSink

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