org.apache.flink.table.factories

Interface StreamTableSourceFactory<T>

Type Parameters:

T - type of records that the factory produces

All Superinterfaces:

TableFactory, TableSourceFactory<T>

All Known Implementing Classes:

CsvAppendTableSourceFactory, HBase1TableFactory, HBase2TableFactory, JdbcTableSourceSinkFactory, KafkaTableSourceSinkFactory, KafkaTableSourceSinkFactoryBase

Deprecated.

This interface has been replaced by DynamicTableSourceFactory. The new interface creates instances of DynamicTableSource and only works with the Blink planner. See FLIP-95 for more information.

@Deprecated
 @PublicEvolving
public interface StreamTableSourceFactory<T>
extends TableSourceFactory<T>

A factory to create configured table source instances in a streaming environment based on string-based properties. See also TableSourceFactory for more information.

Nested Class Summary

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

TableSourceFactory.Context

Method Summary

Modifier and Type	Method and Description
default StreamTableSource<T>	createStreamTableSource(Map<String,String> properties) Deprecated. Context contains more information, and already contains table schema too. Please use TableSourceFactory.createTableSource(Context) instead.
default TableSource<T>	createTableSource(Map<String,String> properties) Deprecated. Only create a stream table source.

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

createTableSource, createTableSource

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

requiredContext, supportedProperties

Method Detail

createStreamTableSource

@Deprecated
default StreamTableSource<T> createStreamTableSource(Map<String,String> properties)

Deprecated. Context contains more information, and already contains table schema too. Please use TableSourceFactory.createTableSource(Context) instead.

Creates and configures a StreamTableSource using the given properties.

Parameters:

properties - normalized properties describing a stream table source.

Returns:

the configured stream table source.

createTableSource

default TableSource<T> createTableSource(Map<String,String> properties)

Deprecated.

Only create a stream table source.

Specified by:

createTableSource in interface TableSourceFactory<T>

Parameters:

properties - normalized properties describing a table source.

Returns:

the configured table source.