Uses of Interface
org.apache.flink.table.connector.sink.DynamicTableSink

Packages that use DynamicTableSink

Package	Description
org.apache.flink.connector.base.table.sink
org.apache.flink.connector.blackhole.table
org.apache.flink.connector.file.table
org.apache.flink.connector.firehose.table
org.apache.flink.connector.hbase1
org.apache.flink.connector.hbase1.sink
org.apache.flink.connector.hbase2
org.apache.flink.connector.hbase2.sink
org.apache.flink.connector.jdbc.table
org.apache.flink.connector.kinesis.table
org.apache.flink.connector.print.table
org.apache.flink.connector.upserttest.table
org.apache.flink.connectors.hive
org.apache.flink.streaming.connectors.elasticsearch.table
org.apache.flink.streaming.connectors.kafka.table
org.apache.flink.table.connector.sink
org.apache.flink.table.factories
org.apache.flink.table.planner.connectors
org.apache.flink.table.planner.plan.abilities.sink
org.apache.flink.table.planner.plan.nodes.exec.common
org.apache.flink.table.planner.plan.nodes.exec.spec

Uses of DynamicTableSink in org.apache.flink.connector.base.table.sink

Classes in org.apache.flink.connector.base.table.sink that implement DynamicTableSink

Modifier and Type	Class and Description
class	AsyncDynamicTableSink<RequestEntryT extends Serializable> Abstract wrapper class for DynamicTableSink with attributes of AsyncSinkBase.

Uses of DynamicTableSink in org.apache.flink.connector.blackhole.table

Methods in org.apache.flink.connector.blackhole.table that return DynamicTableSink

Modifier and Type	Method and Description
DynamicTableSink	BlackHoleTableSinkFactory.createDynamicTableSink(DynamicTableFactory.Context context)

Uses of DynamicTableSink in org.apache.flink.connector.file.table

Classes in org.apache.flink.connector.file.table that implement DynamicTableSink

Modifier and Type	Class and Description
class	FileSystemTableSink File system DynamicTableSink.

Methods in org.apache.flink.connector.file.table that return DynamicTableSink

Modifier and Type	Method and Description
DynamicTableSink	FileSystemTableSink.copy()
DynamicTableSink	FileSystemTableFactory.createDynamicTableSink(DynamicTableFactory.Context context)

Uses of DynamicTableSink in org.apache.flink.connector.firehose.table

Classes in org.apache.flink.connector.firehose.table that implement DynamicTableSink

Modifier and Type	Class and Description
class	KinesisFirehoseDynamicSink Kinesis firehose backed AsyncDynamicTableSink.

Methods in org.apache.flink.connector.firehose.table that return DynamicTableSink

Modifier and Type	Method and Description
DynamicTableSink	KinesisFirehoseDynamicSink.copy()
DynamicTableSink	KinesisFirehoseDynamicTableFactory.createDynamicTableSink(DynamicTableFactory.Context context)

Uses of DynamicTableSink in org.apache.flink.connector.hbase1

Methods in org.apache.flink.connector.hbase1 that return DynamicTableSink

Modifier and Type	Method and Description
DynamicTableSink	HBase1DynamicTableFactory.createDynamicTableSink(DynamicTableFactory.Context context)

Uses of DynamicTableSink in org.apache.flink.connector.hbase1.sink

Classes in org.apache.flink.connector.hbase1.sink that implement DynamicTableSink

Modifier and Type	Class and Description
class	HBaseDynamicTableSink HBase table sink implementation.

Methods in org.apache.flink.connector.hbase1.sink that return DynamicTableSink

Modifier and Type	Method and Description
DynamicTableSink	HBaseDynamicTableSink.copy()

Uses of DynamicTableSink in org.apache.flink.connector.hbase2

Methods in org.apache.flink.connector.hbase2 that return DynamicTableSink

Modifier and Type	Method and Description
DynamicTableSink	HBase2DynamicTableFactory.createDynamicTableSink(DynamicTableFactory.Context context)

Uses of DynamicTableSink in org.apache.flink.connector.hbase2.sink

Methods in org.apache.flink.connector.hbase2.sink that return DynamicTableSink

Modifier and Type	Method and Description
DynamicTableSink	HBaseDynamicTableSink.copy()

Uses of DynamicTableSink in org.apache.flink.connector.jdbc.table

Classes in org.apache.flink.connector.jdbc.table that implement DynamicTableSink

Modifier and Type	Class and Description
class	JdbcDynamicTableSink A DynamicTableSink for JDBC.

Methods in org.apache.flink.connector.jdbc.table that return DynamicTableSink

Modifier and Type	Method and Description
DynamicTableSink	JdbcDynamicTableSink.copy()
DynamicTableSink	JdbcDynamicTableFactory.createDynamicTableSink(DynamicTableFactory.Context context)

Uses of DynamicTableSink in org.apache.flink.connector.kinesis.table

Classes in org.apache.flink.connector.kinesis.table that implement DynamicTableSink

Modifier and Type	Class and Description
class	KinesisDynamicSink Kinesis backed AsyncDynamicTableSink.

Methods in org.apache.flink.connector.kinesis.table that return DynamicTableSink

Modifier and Type	Method and Description
DynamicTableSink	KinesisDynamicSink.copy()
DynamicTableSink	KinesisDynamicTableSinkFactory.createDynamicTableSink(DynamicTableFactory.Context context)

Uses of DynamicTableSink in org.apache.flink.connector.print.table

Methods in org.apache.flink.connector.print.table that return DynamicTableSink

Modifier and Type	Method and Description
DynamicTableSink	PrintTableSinkFactory.createDynamicTableSink(DynamicTableFactory.Context context)

Uses of DynamicTableSink in org.apache.flink.connector.upserttest.table

Methods in org.apache.flink.connector.upserttest.table that return DynamicTableSink

Modifier and Type	Method and Description
DynamicTableSink	UpsertTestDynamicTableSinkFactory.createDynamicTableSink(DynamicTableFactory.Context context)

Uses of DynamicTableSink in org.apache.flink.connectors.hive

Classes in org.apache.flink.connectors.hive that implement DynamicTableSink

Modifier and Type	Class and Description
class	HiveTableSink Table sink to write to Hive tables.

Methods in org.apache.flink.connectors.hive that return DynamicTableSink

Modifier and Type	Method and Description
DynamicTableSink	HiveTableSink.copy()
DynamicTableSink	HiveDynamicTableFactory.createDynamicTableSink(DynamicTableFactory.Context context)

Uses of DynamicTableSink in org.apache.flink.streaming.connectors.elasticsearch.table

Methods in org.apache.flink.streaming.connectors.elasticsearch.table that return DynamicTableSink

Modifier and Type	Method and Description
DynamicTableSink	Elasticsearch6DynamicSinkFactory.createDynamicTableSink(DynamicTableFactory.Context context)
DynamicTableSink	Elasticsearch7DynamicSinkFactory.createDynamicTableSink(DynamicTableFactory.Context context)

Uses of DynamicTableSink in org.apache.flink.streaming.connectors.kafka.table

Classes in org.apache.flink.streaming.connectors.kafka.table that implement DynamicTableSink

Modifier and Type	Class and Description
class	KafkaDynamicSink A version-agnostic Kafka DynamicTableSink.

Methods in org.apache.flink.streaming.connectors.kafka.table that return DynamicTableSink

Modifier and Type	Method and Description
DynamicTableSink	KafkaDynamicSink.copy()
DynamicTableSink	KafkaDynamicTableFactory.createDynamicTableSink(DynamicTableFactory.Context context)
DynamicTableSink	UpsertKafkaDynamicTableFactory.createDynamicTableSink(DynamicTableFactory.Context context)

Uses of DynamicTableSink in org.apache.flink.table.connector.sink

Methods in org.apache.flink.table.connector.sink that return DynamicTableSink

Modifier and Type	Method and Description
DynamicTableSink	DynamicTableSink.copy() Creates a copy of this instance during planning.

Uses of DynamicTableSink in org.apache.flink.table.factories

Methods in org.apache.flink.table.factories that return DynamicTableSink

Modifier and Type	Method and Description
DynamicTableSink	DynamicTableSinkFactory.createDynamicTableSink(DynamicTableFactory.Context context) Creates a DynamicTableSink instance from a CatalogTable and additional context information.
static DynamicTableSink	FactoryUtil.createDynamicTableSink(DynamicTableSinkFactory preferredFactory, ObjectIdentifier objectIdentifier, ResolvedCatalogTable catalogTable, Map<String,String> enrichmentOptions, ReadableConfig configuration, ClassLoader classLoader, boolean isTemporary) Creates a DynamicTableSink from a CatalogTable.
static DynamicTableSink	FactoryUtil.createDynamicTableSink(DynamicTableSinkFactory preferredFactory, ObjectIdentifier objectIdentifier, ResolvedCatalogTable catalogTable, ReadableConfig configuration, ClassLoader classLoader, boolean isTemporary) Deprecated. Use FactoryUtil.createDynamicTableSink(DynamicTableSinkFactory, ObjectIdentifier, ResolvedCatalogTable, Map, ReadableConfig, ClassLoader, boolean)
static DynamicTableSink	FactoryUtil.createTableSink(Catalog catalog, ObjectIdentifier objectIdentifier, ResolvedCatalogTable catalogTable, ReadableConfig configuration, ClassLoader classLoader, boolean isTemporary) Deprecated. Use FactoryUtil.createDynamicTableSink(DynamicTableSinkFactory, ObjectIdentifier, ResolvedCatalogTable, Map, ReadableConfig, ClassLoader, boolean) instead.

Uses of DynamicTableSink in org.apache.flink.table.planner.connectors

Classes in org.apache.flink.table.planner.connectors that implement DynamicTableSink

Modifier and Type	Class and Description
class	CollectDynamicSink Table sink for TableResult.collect().

Methods in org.apache.flink.table.planner.connectors that return DynamicTableSink

Modifier and Type	Method and Description
DynamicTableSink	CollectDynamicSink.copy()

Methods in org.apache.flink.table.planner.connectors with parameters of type DynamicTableSink

Modifier and Type	Method and Description
static org.apache.calcite.rel.RelNode	DynamicSinkUtils.convertSinkToRel(FlinkRelBuilder relBuilder, org.apache.calcite.rel.RelNode input, SinkModifyOperation sinkModifyOperation, DynamicTableSink sink) Converts a given DynamicTableSink to a RelNode.

Uses of DynamicTableSink in org.apache.flink.table.planner.plan.abilities.sink

Methods in org.apache.flink.table.planner.plan.abilities.sink with parameters of type DynamicTableSink

Modifier and Type	Method and Description
void	SinkAbilitySpec.apply(DynamicTableSink tableSink) Apply the ability to the given DynamicTableSink.
void	WritingMetadataSpec.apply(DynamicTableSink tableSink)
void	OverwriteSpec.apply(DynamicTableSink tableSink)
void	PartitioningSpec.apply(DynamicTableSink tableSink)

Uses of DynamicTableSink in org.apache.flink.table.planner.plan.nodes.exec.common

Methods in org.apache.flink.table.planner.plan.nodes.exec.common with parameters of type DynamicTableSink

Modifier and Type	Method and Description
protected Transformation<Object>	CommonExecSink.createSinkTransformation(StreamExecutionEnvironment streamExecEnv, ExecNodeConfig config, ClassLoader classLoader, Transformation<RowData> inputTransform, DynamicTableSink tableSink, int rowtimeFieldIndex, boolean upsertMaterialize, int[] inputUpsertKey)

Uses of DynamicTableSink in org.apache.flink.table.planner.plan.nodes.exec.spec

Methods in org.apache.flink.table.planner.plan.nodes.exec.spec that return DynamicTableSink

Modifier and Type	Method and Description
DynamicTableSink	DynamicTableSinkSpec.getTableSink(org.apache.flink.table.planner.calcite.FlinkContext context)

Methods in org.apache.flink.table.planner.plan.nodes.exec.spec with parameters of type DynamicTableSink

Modifier and Type	Method and Description
void	DynamicTableSinkSpec.setTableSink(DynamicTableSink tableSink)