org.apache.flink.table.factories

接口 StreamTableSourceFactory<T>

类型参数:

T - type of records that the factory produces

所有超级接口:

org.apache.flink.table.factories.TableFactory, org.apache.flink.table.factories.TableSourceFactory<T>

所有已知实现类:

CsvAppendTableSourceFactory, CsvBatchTableSourceFactory

已过时。

This interface has been replaced by DynamicTableSourceFactory. The new interface creates instances of DynamicTableSource. See FLIP-95 for more information.

@Deprecated
 @PublicEvolving
public interface StreamTableSourceFactory<T>
extends org.apache.flink.table.factories.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.

嵌套类概要

从接口继承的嵌套类/接口 org.apache.flink.table.factories.TableSourceFactory

org.apache.flink.table.factories.TableSourceFactory.Context

方法概要

限定符和类型	方法和说明
default StreamTableSource<T>	createStreamTableSource(Map<String,String> properties) 已过时。 Context contains more information, and already contains table schema too. Please use TableSourceFactory.createTableSource(Context) instead.
default org.apache.flink.table.sources.TableSource<T>	createTableSource(Map<String,String> properties) 已过时。 Only create a stream table source.

从接口继承的方法 org.apache.flink.table.factories.TableSourceFactory

createTableSource, createTableSource

从接口继承的方法 org.apache.flink.table.factories.TableFactory

requiredContext, supportedProperties

方法详细资料

createStreamTableSource

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

已过时。 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.

参数:

properties - normalized properties describing a stream table source.

返回:

the configured stream table source.

createTableSource

default org.apache.flink.table.sources.TableSource<T> createTableSource(Map<String,String> properties)

已过时。

Only create a stream table source.

指定者:

createTableSource 在接口中 org.apache.flink.table.factories.TableSourceFactory<T>