org.apache.flink.table.connector.source

Interface DataStreamScanProvider

All Superinterfaces:

ScanTableSource.ScanRuntimeProvider

@PublicEvolving
public interface DataStreamScanProvider
extends ScanTableSource.ScanRuntimeProvider

Provider that produces a Java DataStream as a runtime implementation for ScanTableSource.

Note: This provider is only meant for advanced connector developers. Usually, a source should consist of a single entity expressed via SourceProvider, SourceFunctionProvider, or InputFormatProvider.

Method Summary

Modifier and Type	Method and Description
default DataStream<RowData>	produceDataStream(ProviderContext providerContext, StreamExecutionEnvironment execEnv) Creates a scan Java DataStream from a StreamExecutionEnvironment.
default DataStream<RowData>	produceDataStream(StreamExecutionEnvironment execEnv) Deprecated.

Methods inherited from interface org.apache.flink.table.connector.source.ScanTableSource.ScanRuntimeProvider

isBounded

Method Detail

produceDataStream

default DataStream<RowData> produceDataStream(ProviderContext providerContext,
                                              StreamExecutionEnvironment execEnv)

Creates a scan Java DataStream from a StreamExecutionEnvironment.

Note: If the CompiledPlan feature should be supported, this method MUST set a unique identifier for each transformation/operator in the data stream. This enables stateful Flink version upgrades for streaming jobs. The identifier is used to map state back from a savepoint to an actual operator in the topology. The framework can generate topology-wide unique identifiers with ProviderContext.generateUid(String).

See Also:

SingleOutputStreamOperator.uid(String)

produceDataStream

@Deprecated
default DataStream<RowData> produceDataStream(StreamExecutionEnvironment execEnv)

Deprecated.

Creates a scan Java DataStream from a StreamExecutionEnvironment.