org.apache.flink.table.runtime.connector.source

Class ScanRuntimeProviderContext

java.lang.Object

org.apache.flink.table.runtime.connector.source.ScanRuntimeProviderContext

All Implemented Interfaces:

DynamicTableSource.Context, ScanTableSource.ScanContext

@Internal
public final class ScanRuntimeProviderContext
extends Object
implements ScanTableSource.ScanContext

Implementation of ScanTableSource.Context.

Field Summary

Fields

Modifier and Type	Field and Description
static ScanRuntimeProviderContext	INSTANCE

Constructor Summary

Constructors

Constructor and Description
ScanRuntimeProviderContext()

Method Summary

Modifier and Type	Method and 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.
TypeInformation<?>	createTypeInformation(DataType producedDataType) Creates type information describing the internal data structures of the given DataType.
TypeInformation<?>	createTypeInformation(LogicalType producedLogicalType) Creates type information describing the internal data structures of the given LogicalType.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

INSTANCE

public static final ScanRuntimeProviderContext INSTANCE

Constructor Detail

ScanRuntimeProviderContext

public ScanRuntimeProviderContext()

Method Detail

createTypeInformation

public TypeInformation<?> createTypeInformation(DataType producedDataType)

Description copied from interface: DynamicTableSource.Context

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

Specified by:

createTypeInformation in interface DynamicTableSource.Context

See Also:

ResolvedSchema.toPhysicalRowDataType()

createTypeInformation

public TypeInformation<?> createTypeInformation(LogicalType producedLogicalType)

Description copied from interface: DynamicTableSource.Context

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

Specified by:

createTypeInformation in interface DynamicTableSource.Context

createDataStructureConverter

public DynamicTableSource.DataStructureConverter createDataStructureConverter(DataType producedDataType)

Description copied from interface: DynamicTableSource.Context

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.

Specified by:

createDataStructureConverter in interface DynamicTableSource.Context

See Also:

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