Interface TransformationScanProvider
-
- All Superinterfaces:
ParallelismProvider
,ScanTableSource.ScanRuntimeProvider
@Internal public interface TransformationScanProvider extends ScanTableSource.ScanRuntimeProvider, ParallelismProvider
Provider that produces aTransformation
as a runtime implementation forScanTableSource
.Note: This provider is only meant for advanced connector developers. Usually, a source should consist of a single entity expressed via
InputFormatProvider
,SourceFunctionProvider
, orSourceProvider
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Transformation<RowData>
createTransformation(ProviderContext providerContext)
Creates aTransformation
instance.-
Methods inherited from interface org.apache.flink.table.connector.ParallelismProvider
getParallelism
-
Methods inherited from interface org.apache.flink.table.connector.source.ScanTableSource.ScanRuntimeProvider
isBounded
-
-
-
-
Method Detail
-
createTransformation
Transformation<RowData> createTransformation(ProviderContext providerContext)
Creates aTransformation
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 withProviderContext.generateUid(String)
.- See Also:
Transformation.setUid(String)
-
-