org.apache.flink.table.planner.connectors

Interface TransformationScanProvider

All Superinterfaces:

ParallelismProvider, ScanTableSource.ScanRuntimeProvider

@Internal
public interface TransformationScanProvider
extends ScanTableSource.ScanRuntimeProvider, ParallelismProvider

Provider that produces a Transformation 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 InputFormatProvider, SourceFunctionProvider, or SourceProvider.

Method Summary

Modifier and Type	Method and Description
Transformation<RowData>	createTransformation(ProviderContext providerContext) Creates a Transformation instance.

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

isBounded

Methods inherited from interface org.apache.flink.table.connector.ParallelismProvider

getParallelism

Method Detail

createTransformation

Transformation<RowData> createTransformation(ProviderContext providerContext)

Creates a Transformation instance.

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:

Transformation.setUid(String)