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 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 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
All Methods Instance Methods Concrete Methods Modifier and Type Method 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)
-
-
-
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 interfaceorg.apache.flink.table.connector.sink.DynamicTableSink
-
applyStaticPartition
public void applyStaticPartition(java.util.Map<java.lang.String,java.lang.String> partition)
- 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
public java.lang.String 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
-
-