Package | Description |
---|---|
org.apache.flink.table.data.conversion | |
org.apache.flink.table.runtime.operators.join.lookup |
Modifier and Type | Class and 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>
|
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
|
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>
|
class |
RawByteArrayConverter<T>
Converter for
RawType of byte[] external type. |
class |
RawObjectConverter<T>
Converter for
RawType of object external type. |
class |
RowRowConverter
|
class |
StringByteArrayConverter
|
class |
StringStringConverter
|
class |
StructuredObjectConverter<T>
Converter for
StructuredType of its implementation class. |
class |
TimeLocalTimeConverter
Converter for
TimeType of LocalTime external type. |
class |
TimeLongConverter
|
class |
TimestampLocalDateTimeConverter
Converter for
TimestampType of LocalDateTime external type. |
class |
TimestampTimestampConverter
Converter for
TimestampType of Timestamp external type. |
class |
TimeTimeConverter
|
class |
YearMonthIntervalPeriodConverter
Converter for
YearMonthIntervalType of Period external type. |
Modifier and Type | Method and Description |
---|---|
static DataStructureConverter<Object,Object> |
DataStructureConverters.getConverter(DataType dataType)
Returns a converter for the given
DataType . |
Constructor and Description |
---|
AsyncLookupJoinRunner(GeneratedFunction<AsyncFunction<RowData,Object>> generatedFetcher,
DataStructureConverter<RowData,Object> fetcherConverter,
GeneratedResultFuture<TableFunctionResultFuture<RowData>> generatedResultFuture,
RowDataSerializer rightRowSerializer,
boolean isLeftOuterJoin,
int asyncBufferCapacity) |
AsyncLookupJoinWithCalcRunner(GeneratedFunction<AsyncFunction<RowData,Object>> generatedFetcher,
DataStructureConverter<RowData,Object> fetcherConverter,
GeneratedFunction<FlatMapFunction<RowData,RowData>> generatedCalc,
GeneratedResultFuture<TableFunctionResultFuture<RowData>> generatedResultFuture,
RowDataSerializer rightRowSerializer,
boolean isLeftOuterJoin,
int asyncBufferCapacity) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.