Uses of Interface
org.apache.flink.table.data.conversion.DataStructureConverter

Packages that use DataStructureConverter

Package	Description
org.apache.flink.table.data.conversion
org.apache.flink.table.runtime.operators.calc.async
org.apache.flink.table.runtime.operators.join.lookup

Uses of DataStructureConverter in org.apache.flink.table.data.conversion

Classes in org.apache.flink.table.data.conversion that implement DataStructureConverter

Modifier and Type	Class	Description
class	ArrayBooleanArrayConverter	Converter for ArrayType of boolean[] external type.
class	ArrayByteArrayConverter	Converter for ArrayType of byte[] external type.
class	ArrayDoubleArrayConverter	Converter for ArrayType of double[] external type.
class	ArrayFloatArrayConverter	Converter for ArrayType of float[] external type.
class	ArrayIntArrayConverter	Converter for ArrayType of int[] external type.
class	ArrayListConverter<E>	Converter for ArrayType of List external type.
class	ArrayLongArrayConverter	Converter for ArrayType of long[] external type.
class	ArrayObjectArrayConverter<E>	Converter for ArrayType of nested primitive or object arrays external types.
class	ArrayShortArrayConverter	Converter for ArrayType of short[] external type.
class	DateDateConverter	Converter for DateType of Date external type.
class	DateLocalDateConverter	Converter for DateType of LocalDate external type.
class	DayTimeIntervalDurationConverter	Converter for DayTimeIntervalType of Duration external type.
class	DecimalBigDecimalConverter	Converter for DecimalType of BigDecimal external type.
class	IdentityConverter<I>	No-op converter that just forwards its input.
class	LocalZonedTimestampInstantConverter	Converter for LocalZonedTimestampType of Instant external type.
class	LocalZonedTimestampIntConverter	Converter for LocalZonedTimestampType of Integer external type.
class	LocalZonedTimestampLongConverter	Converter for LocalZonedTimestampType of Long external type.
class	LocalZonedTimestampTimestampConverter	Converter for LocalZonedTimestampType of Timestamp external type.
class	MapMapConverter<K,V>	Converter for MapType/MultisetType of Map external type.
class	RawByteArrayConverter<T>	Converter for RawType of byte[] external type.
class	RawObjectConverter<T>	Converter for RawType of object external type.
class	RowRowConverter	Converter for RowType of Row external type.
class	StringByteArrayConverter	Converter for CharType/VarCharType of byte[] external type.
class	StringStringConverter	Converter for CharType/VarCharType of String external type.
class	StructuredObjectConverter<T>	Converter for StructuredType of its implementation class.
class	TimeLocalTimeConverter	Converter for TimeType of LocalTime external type.
class	TimeLongConverter	Converter for TimeType of Long external type.
class	TimestampLocalDateTimeConverter	Converter for TimestampType of LocalDateTime external type.
class	TimestampTimestampConverter	Converter for TimestampType of Timestamp external type.
class	TimeTimeConverter	Converter for TimeType of Time external type.
class	YearMonthIntervalPeriodConverter	Converter for YearMonthIntervalType of Period external type.

Methods in org.apache.flink.table.data.conversion that return DataStructureConverter

Modifier and Type	Method	Description
static DataStructureConverter<Object,Object>	DataStructureConverters.getConverter(org.apache.flink.table.types.DataType dataType)	Returns a converter for the given DataType.

Uses of DataStructureConverter in org.apache.flink.table.runtime.operators.calc.async

Methods in org.apache.flink.table.runtime.operators.calc.async with parameters of type DataStructureConverter

Modifier and Type	Method	Description
CompletableFuture<?>	DelegatingAsyncResultFuture.createAsyncFuture(DataStructureConverter<Object,Object> converter)

Uses of DataStructureConverter in org.apache.flink.table.runtime.operators.join.lookup

Constructors in org.apache.flink.table.runtime.operators.join.lookup with parameters of type DataStructureConverter

Constructor	Description
AsyncLookupJoinRunner(GeneratedFunction<org.apache.flink.streaming.api.functions.async.AsyncFunction<org.apache.flink.table.data.RowData,Object>> generatedFetcher, DataStructureConverter<org.apache.flink.table.data.RowData,Object> fetcherConverter, GeneratedResultFuture<TableFunctionResultFuture<org.apache.flink.table.data.RowData>> generatedResultFuture, GeneratedFunction<FilterCondition> generatedPreFilterCondition, RowDataSerializer rightRowSerializer, boolean isLeftOuterJoin, int asyncBufferCapacity)
AsyncLookupJoinWithCalcRunner(GeneratedFunction<org.apache.flink.streaming.api.functions.async.AsyncFunction<org.apache.flink.table.data.RowData,Object>> generatedFetcher, DataStructureConverter<org.apache.flink.table.data.RowData,Object> fetcherConverter, GeneratedFunction<org.apache.flink.api.common.functions.FlatMapFunction<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>> generatedCalc, GeneratedResultFuture<TableFunctionResultFuture<org.apache.flink.table.data.RowData>> generatedResultFuture, GeneratedFunction<FilterCondition> generatedPreFilterCondition, RowDataSerializer rightRowSerializer, boolean isLeftOuterJoin, int asyncBufferCapacity)