org.apache.iceberg.flink

Class IcebergTableSink

java.lang.Object

org.apache.iceberg.flink.IcebergTableSink

All Implemented Interfaces:

org.apache.flink.table.sinks.AppendStreamTableSink<org.apache.flink.table.data.RowData>, org.apache.flink.table.sinks.OverwritableTableSink, org.apache.flink.table.sinks.PartitionableTableSink, org.apache.flink.table.sinks.StreamTableSink<org.apache.flink.table.data.RowData>, org.apache.flink.table.sinks.TableSink<org.apache.flink.table.data.RowData>

public class IcebergTableSink
extends java.lang.Object
implements org.apache.flink.table.sinks.AppendStreamTableSink<org.apache.flink.table.data.RowData>, org.apache.flink.table.sinks.OverwritableTableSink, org.apache.flink.table.sinks.PartitionableTableSink

Constructor Summary

Constructors

Constructor and Description
IcebergTableSink(boolean isBounded, TableLoader tableLoader, org.apache.flink.table.api.TableSchema tableSchema)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.table.sinks.TableSink<org.apache.flink.table.data.RowData>	configure(java.lang.String[] fieldNames, org.apache.flink.api.common.typeinfo.TypeInformation<?>[] fieldTypes)
org.apache.flink.streaming.api.datastream.DataStreamSink<?>	consumeDataStream(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> dataStream)
org.apache.flink.table.types.DataType	getConsumedDataType()
org.apache.flink.table.api.TableSchema	getTableSchema()
void	setOverwrite(boolean overwrite)
void	setStaticPartition(java.util.Map<java.lang.String,java.lang.String> partitions)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.table.sinks.TableSink

getFieldNames, getFieldTypes, getOutputType

Methods inherited from interface org.apache.flink.table.sinks.PartitionableTableSink

configurePartitionGrouping

Constructor Detail

IcebergTableSink

public IcebergTableSink(boolean isBounded,
                        TableLoader tableLoader,
                        org.apache.flink.table.api.TableSchema tableSchema)

Method Detail

consumeDataStream

public org.apache.flink.streaming.api.datastream.DataStreamSink<?> consumeDataStream(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> dataStream)

Specified by:

consumeDataStream in interface org.apache.flink.table.sinks.StreamTableSink<org.apache.flink.table.data.RowData>

getConsumedDataType

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

Specified by:

getConsumedDataType in interface org.apache.flink.table.sinks.TableSink<org.apache.flink.table.data.RowData>

getTableSchema

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

Specified by:

getTableSchema in interface org.apache.flink.table.sinks.TableSink<org.apache.flink.table.data.RowData>

configure

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

Specified by:

configure in interface org.apache.flink.table.sinks.TableSink<org.apache.flink.table.data.RowData>

setOverwrite

public void setOverwrite(boolean overwrite)

Specified by:

setOverwrite in interface org.apache.flink.table.sinks.OverwritableTableSink

setStaticPartition

public void setStaticPartition(java.util.Map<java.lang.String,java.lang.String> partitions)

Specified by:

setStaticPartition in interface org.apache.flink.table.sinks.PartitionableTableSink