org.apache.paimon.flink.sink

Class FlinkTableSinkBase

java.lang.Object

org.apache.paimon.flink.sink.FlinkTableSinkBase

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

Direct Known Subclasses:

SupportsRowLevelOperationFlinkTableSink

public abstract class FlinkTableSinkBase
extends Object
implements org.apache.flink.table.connector.sink.DynamicTableSink, org.apache.flink.table.connector.sink.abilities.SupportsOverwrite, org.apache.flink.table.connector.sink.abilities.SupportsPartitioning

Table sink to create sink.

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

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.flink.table.factories.DynamicTableFactory.Context	context
protected LogStoreTableFactory	logStoreTableFactory
protected boolean	overwrite
protected Map<String,String>	staticPartitions
protected Table	table
protected org.apache.flink.table.catalog.ObjectIdentifier	tableIdentifier

Constructor Summary

Constructors

Constructor and Description
FlinkTableSinkBase(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	applyOverwrite(boolean overwrite)
void	applyStaticPartition(Map<String,String> partition)
String	asSummaryString()
org.apache.flink.table.connector.sink.DynamicTableSink	copy()
protected LogFlinkSinkBuilder	createSinkBuilder()
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

Field Detail

tableIdentifier

protected final org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier

context

protected final org.apache.flink.table.factories.DynamicTableFactory.Context context

logStoreTableFactory

@Nullable
protected final LogStoreTableFactory logStoreTableFactory

table

protected final Table table

staticPartitions

protected Map<String,String> staticPartitions

overwrite

protected boolean overwrite

Constructor Detail

FlinkTableSinkBase

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

Method Detail

getChangelogMode

public org.apache.flink.table.connector.ChangelogMode getChangelogMode(org.apache.flink.table.connector.ChangelogMode requestedMode)

Specified by:

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

getSinkRuntimeProvider

public org.apache.flink.table.connector.sink.DynamicTableSink.SinkRuntimeProvider getSinkRuntimeProvider(org.apache.flink.table.connector.sink.DynamicTableSink.Context context)

Specified by:

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

createSinkBuilder

protected LogFlinkSinkBuilder createSinkBuilder()

copy

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

Specified by:

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

asSummaryString

public String asSummaryString()

Specified by:

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

applyStaticPartition

public void applyStaticPartition(Map<String,String> partition)

Specified by:

applyStaticPartition in interface org.apache.flink.table.connector.sink.abilities.SupportsPartitioning

applyOverwrite

public void applyOverwrite(boolean overwrite)

Specified by:

applyOverwrite in interface org.apache.flink.table.connector.sink.abilities.SupportsOverwrite