Interface DynamicTableSource.Context
-
- All Known Subinterfaces:
LookupTableSource.LookupContext
,ScanTableSource.ScanContext
- All Known Implementing Classes:
LookupRuntimeProviderContext
,ScanRuntimeProviderContext
- Enclosing interface:
- DynamicTableSource
@PublicEvolving public static interface DynamicTableSource.Context
Base context for creating runtime implementation via aScanTableSource.ScanRuntimeProvider
andLookupTableSource.LookupRuntimeProvider
.It offers utilities by the planner for creating runtime implementation with minimal dependencies to internal data structures.
Methods should be called in
ScanTableSource.getScanRuntimeProvider(ScanTableSource.ScanContext)
andLookupTableSource.getLookupRuntimeProvider(LookupTableSource.LookupContext)
. The returned instances areSerializable
and can be directly passed into the runtime implementation class.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description DynamicTableSource.DataStructureConverter
createDataStructureConverter(DataType producedDataType)
Creates a converter for mapping between objects specified by the givenDataType
and Flink's internal data structures that can be passed into a runtime implementation.<T> TypeInformation<T>
createTypeInformation(DataType producedDataType)
Creates type information describing the internal data structures of the givenDataType
.<T> TypeInformation<T>
createTypeInformation(LogicalType producedLogicalType)
Creates type information describing the internal data structures of the givenLogicalType
.
-
-
-
Method Detail
-
createTypeInformation
<T> TypeInformation<T> createTypeInformation(DataType producedDataType)
Creates type information describing the internal data structures of the givenDataType
.- See Also:
ResolvedSchema.toPhysicalRowDataType()
-
createTypeInformation
<T> TypeInformation<T> createTypeInformation(LogicalType producedLogicalType)
Creates type information describing the internal data structures of the givenLogicalType
.
-
createDataStructureConverter
DynamicTableSource.DataStructureConverter createDataStructureConverter(DataType producedDataType)
Creates a converter for mapping between objects specified by the givenDataType
and Flink's internal data structures that can be passed into a runtime implementation.For example, a
Row
and its fields can be converted intoRowData
, or a (possibly nested) POJO can be converted into the internal representation for structured types.
-
-