public class TableStoreSink 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
StoreSink
.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 and Description |
---|
TableStoreSink(org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier,
FileStoreTable table,
org.apache.flink.table.factories.DynamicTableFactory.Context context,
LogStoreTableFactory logStoreTableFactory) |
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() |
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) |
void |
setLockFactory(CatalogLock.Factory lockFactory) |
public TableStoreSink(org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier, FileStoreTable table, org.apache.flink.table.factories.DynamicTableFactory.Context context, @Nullable LogStoreTableFactory logStoreTableFactory)
public org.apache.flink.table.connector.ChangelogMode getChangelogMode(org.apache.flink.table.connector.ChangelogMode requestedMode)
getChangelogMode
in interface org.apache.flink.table.connector.sink.DynamicTableSink
public org.apache.flink.table.connector.sink.DynamicTableSink.SinkRuntimeProvider getSinkRuntimeProvider(org.apache.flink.table.connector.sink.DynamicTableSink.Context context)
getSinkRuntimeProvider
in interface org.apache.flink.table.connector.sink.DynamicTableSink
public org.apache.flink.table.connector.sink.DynamicTableSink copy()
copy
in interface org.apache.flink.table.connector.sink.DynamicTableSink
public String asSummaryString()
asSummaryString
in interface org.apache.flink.table.connector.sink.DynamicTableSink
public void applyStaticPartition(Map<String,String> partition)
applyStaticPartition
in interface org.apache.flink.table.connector.sink.abilities.SupportsPartitioning
public void applyOverwrite(boolean overwrite)
applyOverwrite
in interface org.apache.flink.table.connector.sink.abilities.SupportsOverwrite
public void setLockFactory(@Nullable CatalogLock.Factory lockFactory)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.