org.apache.paimon.flink.sink

Class FlinkTableSink

java.lang.Object

org.apache.paimon.flink.sink.FlinkTableSinkBase

org.apache.paimon.flink.sink.SupportsRowLevelOperationFlinkTableSink

org.apache.paimon.flink.sink.FlinkTableSink

All Implemented Interfaces:

org.apache.flink.table.connector.sink.abilities.SupportsDeletePushDown, org.apache.flink.table.connector.sink.abilities.SupportsOverwrite, org.apache.flink.table.connector.sink.abilities.SupportsPartitioning, org.apache.flink.table.connector.sink.abilities.SupportsRowLevelDelete, org.apache.flink.table.connector.sink.abilities.SupportsRowLevelUpdate, org.apache.flink.table.connector.sink.abilities.SupportsTruncate, org.apache.flink.table.connector.sink.DynamicTableSink

public class FlinkTableSink
extends SupportsRowLevelOperationFlinkTableSink
implements org.apache.flink.table.connector.sink.abilities.SupportsTruncate

Table sink to create sink.

Nested Class Summary

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

org.apache.flink.table.connector.sink.abilities.SupportsRowLevelUpdate.RowLevelUpdateInfo, org.apache.flink.table.connector.sink.abilities.SupportsRowLevelUpdate.RowLevelUpdateMode

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

org.apache.flink.table.connector.sink.abilities.SupportsRowLevelDelete.RowLevelDeleteInfo, org.apache.flink.table.connector.sink.abilities.SupportsRowLevelDelete.RowLevelDeleteMode

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

Field Summary

Fields inherited from class org.apache.paimon.flink.sink.SupportsRowLevelOperationFlinkTableSink

deletePredicate

Fields inherited from class org.apache.paimon.flink.sink.FlinkTableSinkBase

context, logStoreTableFactory, overwrite, staticPartitions, table, tableIdentifier

Constructor Summary

Constructors

Constructor and Description
FlinkTableSink(org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier, Table table, org.apache.flink.table.factories.DynamicTableFactory.Context context, LogStoreTableFactory logStoreTableFactory)

Method Summary

Modifier and Type	Method and Description
void	executeTruncation()

Methods inherited from class org.apache.paimon.flink.sink.SupportsRowLevelOperationFlinkTableSink

applyDeleteFilters, applyRowLevelDelete, applyRowLevelUpdate, copy, executeDeletion

Methods inherited from class org.apache.paimon.flink.sink.FlinkTableSinkBase

applyOverwrite, applyStaticPartition, asSummaryString, createSinkBuilder, getChangelogMode, getSinkRuntimeProvider

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

FlinkTableSink

public FlinkTableSink(org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier,
                      Table table,
                      org.apache.flink.table.factories.DynamicTableFactory.Context context,
                      @Nullable
                      LogStoreTableFactory logStoreTableFactory)

Method Detail

executeTruncation

public void executeTruncation()

Specified by:

executeTruncation in interface org.apache.flink.table.connector.sink.abilities.SupportsTruncate