Package org.apache.flink.table.connector.source

Interface DynamicTableSource.Context

Enclosing interface:

DynamicTableSource

@PublicEvolving
public static interface DynamicTableSource.Context

Base context for creating runtime implementation via a ScanTableSource.ScanRuntimeProvider and LookupTableSource.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) and LookupTableSource.getLookupRuntimeProvider(LookupTableSource.LookupContext). The returned instances are Serializable and can be directly passed into the runtime implementation class.

Method Summary

Modifier and Type	Method	Description
DynamicTableSource.DataStructureConverter	createDataStructureConverter(DataType producedDataType)	Creates a converter for mapping between objects specified by the given DataType 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 given DataType.
<T> TypeInformation<T>	createTypeInformation(LogicalType producedLogicalType)	Creates type information describing the internal data structures of the given LogicalType.

Method Details

createTypeInformation

<T> TypeInformation<T> createTypeInformation(DataType producedDataType)

Creates type information describing the internal data structures of the given DataType.

See Also:

• ResolvedSchema.toPhysicalRowDataType()

createTypeInformation

<T> TypeInformation<T> createTypeInformation(LogicalType producedLogicalType)

Creates type information describing the internal data structures of the given LogicalType.

createDataStructureConverter

DynamicTableSource.DataStructureConverter createDataStructureConverter(DataType producedDataType)

Creates a converter for mapping between objects specified by the given DataType and Flink's internal data structures that can be passed into a runtime implementation.

For example, a Row and its fields can be converted into RowData, or a (possibly nested) POJO can be converted into the internal representation for structured types.

See Also:

• LogicalType.supportsInputConversion(Class)
• ResolvedSchema.toPhysicalRowDataType()