public class FlinkTableSink extends SupportsRowLevelOperationFlinkTableSink implements org.apache.flink.table.connector.sink.abilities.SupportsTruncate
org.apache.flink.table.connector.sink.abilities.SupportsRowLevelUpdate.RowLevelUpdateInfo, org.apache.flink.table.connector.sink.abilities.SupportsRowLevelUpdate.RowLevelUpdateMode
org.apache.flink.table.connector.sink.abilities.SupportsRowLevelDelete.RowLevelDeleteInfo, org.apache.flink.table.connector.sink.abilities.SupportsRowLevelDelete.RowLevelDeleteMode
org.apache.flink.table.connector.sink.DynamicTableSink.Context, org.apache.flink.table.connector.sink.DynamicTableSink.DataStructureConverter, org.apache.flink.table.connector.sink.DynamicTableSink.SinkRuntimeProvider
deletePredicate
context, logStoreTableFactory, overwrite, staticPartitions, table, tableIdentifier
Constructor and Description |
---|
FlinkTableSink(org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier,
Table table,
org.apache.flink.table.factories.DynamicTableFactory.Context context,
LogStoreTableFactory logStoreTableFactory) |
Modifier and Type | Method and Description |
---|---|
void |
executeTruncation() |
applyDeleteFilters, applyRowLevelDelete, applyRowLevelUpdate, copy, executeDeletion
applyOverwrite, applyStaticPartition, asSummaryString, createSinkBuilder, getChangelogMode, getSinkRuntimeProvider
public FlinkTableSink(org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier, Table table, org.apache.flink.table.factories.DynamicTableFactory.Context context, @Nullable LogStoreTableFactory logStoreTableFactory)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.