Package 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 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
ConstructorDescriptionIcebergTableSink
(TableLoader tableLoader, org.apache.flink.table.api.TableSchema tableSchema, org.apache.flink.configuration.ReadableConfig readableConfig, Map<String, String> writeProps) -
Method Summary
Modifier and TypeMethodDescriptionvoid
applyOverwrite
(boolean newOverwrite) void
applyStaticPartition
(Map<String, String> partition) 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 Details
-
IcebergTableSink
public IcebergTableSink(TableLoader tableLoader, org.apache.flink.table.api.TableSchema tableSchema, org.apache.flink.configuration.ReadableConfig readableConfig, Map<String, String> writeProps)
-
-
Method Details
-
getSinkRuntimeProvider
public org.apache.flink.table.connector.sink.DynamicTableSink.SinkRuntimeProvider getSinkRuntimeProvider(org.apache.flink.table.connector.sink.DynamicTableSink.Context context) - Specified by:
getSinkRuntimeProvider
in interfaceorg.apache.flink.table.connector.sink.DynamicTableSink
-
applyStaticPartition
- Specified by:
applyStaticPartition
in interfaceorg.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 interfaceorg.apache.flink.table.connector.sink.DynamicTableSink
-
copy
public org.apache.flink.table.connector.sink.DynamicTableSink copy()- Specified by:
copy
in interfaceorg.apache.flink.table.connector.sink.DynamicTableSink
-
asSummaryString
- Specified by:
asSummaryString
in interfaceorg.apache.flink.table.connector.sink.DynamicTableSink
-
applyOverwrite
public void applyOverwrite(boolean newOverwrite) - Specified by:
applyOverwrite
in interfaceorg.apache.flink.table.connector.sink.abilities.SupportsOverwrite
-