org.apache.paimon.flink.sink

Class SupportsRowLevelOperationFlinkTableSink

java.lang.Object

org.apache.paimon.flink.sink.FlinkTableSinkBase

org.apache.paimon.flink.sink.SupportsRowLevelOperationFlinkTableSink

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.DynamicTableSink

Direct Known Subclasses:

FlinkTableSink

public abstract class SupportsRowLevelOperationFlinkTableSink
extends FlinkTableSinkBase
implements org.apache.flink.table.connector.sink.abilities.SupportsRowLevelUpdate, org.apache.flink.table.connector.sink.abilities.SupportsRowLevelDelete, org.apache.flink.table.connector.sink.abilities.SupportsDeletePushDown

Flink table sink that supports row level update and delete.

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

Modifier and Type	Field and Description
protected Predicate	deletePredicate

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

context, logStoreTableFactory, overwrite, staticPartitions, table, tableIdentifier

Constructor Summary

Constructors

Constructor and Description
SupportsRowLevelOperationFlinkTableSink(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
boolean	applyDeleteFilters(List<org.apache.flink.table.expressions.ResolvedExpression> list)
org.apache.flink.table.connector.sink.abilities.SupportsRowLevelDelete.RowLevelDeleteInfo	applyRowLevelDelete(org.apache.flink.table.connector.RowLevelModificationScanContext rowLevelModificationScanContext)
org.apache.flink.table.connector.sink.abilities.SupportsRowLevelUpdate.RowLevelUpdateInfo	applyRowLevelUpdate(List<org.apache.flink.table.catalog.Column> updatedColumns, org.apache.flink.table.connector.RowLevelModificationScanContext context)
org.apache.flink.table.connector.sink.DynamicTableSink	copy()
Optional<Long>	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

Field Detail

deletePredicate

@Nullable
protected Predicate deletePredicate

Constructor Detail

SupportsRowLevelOperationFlinkTableSink

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

Method Detail

copy

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

Specified by:

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

Overrides:

copy in class FlinkTableSinkBase

applyRowLevelUpdate

public org.apache.flink.table.connector.sink.abilities.SupportsRowLevelUpdate.RowLevelUpdateInfo applyRowLevelUpdate(List<org.apache.flink.table.catalog.Column> updatedColumns,
                                                                                                                     @Nullable
                                                                                                                     org.apache.flink.table.connector.RowLevelModificationScanContext context)

Specified by:

applyRowLevelUpdate in interface org.apache.flink.table.connector.sink.abilities.SupportsRowLevelUpdate

applyRowLevelDelete

public org.apache.flink.table.connector.sink.abilities.SupportsRowLevelDelete.RowLevelDeleteInfo applyRowLevelDelete(@Nullable
                                                                                                                     org.apache.flink.table.connector.RowLevelModificationScanContext rowLevelModificationScanContext)

Specified by:

applyRowLevelDelete in interface org.apache.flink.table.connector.sink.abilities.SupportsRowLevelDelete

applyDeleteFilters

public boolean applyDeleteFilters(List<org.apache.flink.table.expressions.ResolvedExpression> list)

Specified by:

applyDeleteFilters in interface org.apache.flink.table.connector.sink.abilities.SupportsDeletePushDown

executeDeletion

public Optional<Long> executeDeletion()

Specified by:

executeDeletion in interface org.apache.flink.table.connector.sink.abilities.SupportsDeletePushDown