org.apache.flink.table.factories

Interface DynamicTableSinkFactory

All Superinterfaces:

DynamicTableFactory, Factory

All Known Implementing Classes:

AsyncDynamicTableSinkFactory, BlackHoleTableSinkFactory, FileSystemTableFactory, HiveDynamicTableFactory, PrintTableSinkFactory, UpsertTestDynamicTableSinkFactory

@PublicEvolving
public interface DynamicTableSinkFactory
extends DynamicTableFactory

Creates a DynamicTableSink instance from a CatalogTable and additional context information.

See Factory for more information about the general design of a factory.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.table.factories.DynamicTableFactory

DynamicTableFactory.Context

Method Summary

Modifier and Type	Method and Description
DynamicTableSink	createDynamicTableSink(DynamicTableFactory.Context context) Creates a DynamicTableSink instance from a CatalogTable and additional context information.

Methods inherited from interface org.apache.flink.table.factories.DynamicTableFactory

forwardOptions

Methods inherited from interface org.apache.flink.table.factories.Factory

factoryIdentifier, optionalOptions, requiredOptions

Method Detail

createDynamicTableSink

DynamicTableSink createDynamicTableSink(DynamicTableFactory.Context context)

Creates a DynamicTableSink instance from a CatalogTable and additional context information.

An implementation should perform validation and the discovery of further (nested) factories in this method.