org.apache.flink.table.factories

Interface DynamicTableSourceFactory

All Superinterfaces:

DynamicTableFactory, Factory

All Known Implementing Classes:

DataGenTableSourceFactory, FileSystemTableFactory, HiveDynamicTableFactory, PythonDynamicTableFactory, SocketDynamicTableFactory, TestFileSystemTableFactory, TestScanTableSourceWithWatermarkPushDownFactory

@PublicEvolving
public interface DynamicTableSourceFactory
extends DynamicTableFactory

Creates a DynamicTableSource 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
DynamicTableSource	createDynamicTableSource(DynamicTableFactory.Context context) Creates a DynamicTableSource 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

createDynamicTableSource

DynamicTableSource createDynamicTableSource(DynamicTableFactory.Context context)

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

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