org.apache.iceberg.flink

Class IcebergTableSink

java.lang.Object

org.apache.iceberg.flink.IcebergTableSink

All Implemented Interfaces:

org.apache.flink.table.connector.sink.abilities.SupportsOverwrite, org.apache.flink.table.connector.sink.abilities.SupportsPartitioning, org.apache.flink.table.connector.sink.DynamicTableSink

public class IcebergTableSink
extends java.lang.Object
implements org.apache.flink.table.connector.sink.DynamicTableSink, org.apache.flink.table.connector.sink.abilities.SupportsPartitioning, org.apache.flink.table.connector.sink.abilities.SupportsOverwrite

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.table.connector.sink.DynamicTableSink

org.apache.flink.table.connector.sink.DynamicTableSink.Context, org.apache.flink.table.connector.sink.DynamicTableSink.DataStructureConverter, org.apache.flink.table.connector.sink.DynamicTableSink.SinkRuntimeProvider

Constructor Summary

Constructors

Constructor and Description
IcebergTableSink(TableLoader tableLoader, org.apache.flink.table.api.TableSchema tableSchema, org.apache.flink.configuration.ReadableConfig readableConfig, java.util.Map<java.lang.String,java.lang.String> writeProps)

Method Summary

Modifier and Type	Method and Description
void	applyOverwrite(boolean newOverwrite)
void	applyStaticPartition(java.util.Map<java.lang.String,java.lang.String> partition)
java.lang.String	asSummaryString()
org.apache.flink.table.connector.sink.DynamicTableSink	copy()
org.apache.flink.table.connector.ChangelogMode	getChangelogMode(org.apache.flink.table.connector.ChangelogMode requestedMode)
org.apache.flink.table.connector.sink.DynamicTableSink.SinkRuntimeProvider	getSinkRuntimeProvider(org.apache.flink.table.connector.sink.DynamicTableSink.Context context)

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.connector.sink.abilities.SupportsPartitioning

requiresPartitionGrouping

Constructor Detail

IcebergTableSink

public IcebergTableSink(TableLoader tableLoader,
                        org.apache.flink.table.api.TableSchema tableSchema,
                        org.apache.flink.configuration.ReadableConfig readableConfig,
                        java.util.Map<java.lang.String,java.lang.String> writeProps)

Method Detail

getSinkRuntimeProvider

public org.apache.flink.table.connector.sink.DynamicTableSink.SinkRuntimeProvider getSinkRuntimeProvider(org.apache.flink.table.connector.sink.DynamicTableSink.Context context)

Specified by:

getSinkRuntimeProvider in interface org.apache.flink.table.connector.sink.DynamicTableSink

applyStaticPartition

public void applyStaticPartition(java.util.Map<java.lang.String,java.lang.String> partition)

Specified by:

applyStaticPartition in interface org.apache.flink.table.connector.sink.abilities.SupportsPartitioning

getChangelogMode

public org.apache.flink.table.connector.ChangelogMode getChangelogMode(org.apache.flink.table.connector.ChangelogMode requestedMode)

Specified by:

getChangelogMode in interface org.apache.flink.table.connector.sink.DynamicTableSink

copy

public org.apache.flink.table.connector.sink.DynamicTableSink copy()

Specified by:

copy in interface org.apache.flink.table.connector.sink.DynamicTableSink

asSummaryString

public java.lang.String asSummaryString()

Specified by:

asSummaryString in interface org.apache.flink.table.connector.sink.DynamicTableSink

applyOverwrite

public void applyOverwrite(boolean newOverwrite)

Specified by:

applyOverwrite in interface org.apache.flink.table.connector.sink.abilities.SupportsOverwrite