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

Interface DynamicTableSource.DataStructureConverter

All Superinterfaces:

RuntimeConverter, Serializable

Enclosing interface:

DynamicTableSource

@PublicEvolving
public static interface DynamicTableSource.DataStructureConverter
extends RuntimeConverter

Converter for mapping between objects and Flink's internal data structures during runtime.

On request, the planner will provide a specialized (possibly code generated) converter 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)

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.table.connector.RuntimeConverter

RuntimeConverter.Context

Method Summary

Modifier and Type	Method	Description
Object	toInternal(Object externalStructure)	Converts the given object into an internal data structure.

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

open

Method Detail

toInternal

@Nullable
Object toInternal(@Nullable
                  Object externalStructure)

Converts the given object into an internal data structure.