org.apache.flink.table.factories

Interface DynamicTableFactory

All Superinterfaces:

Factory

All Known Subinterfaces:

DynamicTableSinkFactory, DynamicTableSourceFactory

All Known Implementing Classes:

BlackHoleTableSinkFactory, DataGenTableSourceFactory, Elasticsearch6DynamicSinkFactory, Elasticsearch7DynamicSinkFactory, FileSystemTableFactory, HBase1DynamicTableFactory, HBase2DynamicTableFactory, HiveDynamicTableFactory, JdbcDynamicTableFactory, KafkaDynamicTableFactory, KinesisDynamicTableFactory, PrintTableSinkFactory, SocketDynamicTableFactory, UpsertKafkaDynamicTableFactory

@PublicEvolving
public interface DynamicTableFactory
extends Factory

Base interface for configuring a dynamic table connector for an external storage system from catalog and session information.

Dynamic tables are the core concept of Flink's Table & SQL API for processing both bounded and unbounded data in a unified fashion.

Implement DynamicTableSourceFactory for constructing a DynamicTableSource.

Implement DynamicTableSinkFactory for constructing a DynamicTableSink.

The options FactoryUtil.PROPERTY_VERSION and FactoryUtil.CONNECTOR are implicitly added and must not be declared.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	DynamicTableFactory.Context Provides catalog and session information describing the dynamic table to be accessed.

Method Summary

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

factoryIdentifier, optionalOptions, requiredOptions