AbstractRowDataSerializer<T extends RowData> |
Row serializer, provided paged serialize paged method.
|
ArrayDataSerializer |
|
ArrayDataSerializer.ArrayDataSerializerSnapshot |
|
BigDecimalTypeInfo |
|
BinaryRowDataSerializer |
|
BinaryRowDataSerializer.BinaryRowDataSerializerSnapshot |
|
DecimalDataSerializer |
|
DecimalDataSerializer.DecimalSerializerSnapshot |
|
DecimalDataTypeInfo |
|
ExternalSerializer<I,E> |
A serializer that can serialize and deserialize all data structures defined by a DataType .
|
ExternalSerializer.ExternalSerializerSnapshot<I,E> |
|
ExternalTypeInfo<T> |
Type information that wraps a serializer that originated from a DataType .
|
InternalSerializers |
|
InternalTypeInfo<T> |
Type information that wraps a serializer that originated from a LogicalType .
|
LegacyInstantTypeInfo |
|
LegacyLocalDateTimeTypeInfo |
|
LegacyTimestampTypeInfo |
|
MapDataSerializer |
|
MapDataSerializer.MapDataSerializerSnapshot |
|
PythonTypeUtils |
Utilities for converting Flink logical types, such as convert it to the related TypeSerializer or
ProtoType.
|
PythonTypeUtils.LogicalTypeToConversionClassConverter |
Convert LogicalType to conversion class for flink planner.
|
PythonTypeUtils.LogicalTypeToProtoTypeConverter |
Converter That convert the logicalType to the related Prototype.
|
RawValueDataSerializer<T> |
|
RawValueDataSerializer.RawValueDataSerializerSnapshot<T> |
|
RowDataSerializer |
|
RowDataSerializer.RowDataSerializerSnapshot |
|
SortedMapSerializer<K,V> |
|
SortedMapSerializerSnapshot<K,V> |
|
SortedMapTypeInfo<K,V> |
The type information for sorted maps.
|
StringDataSerializer |
|
StringDataSerializer.StringDataSerializerSnapshot |
Serializer configuration snapshot for compatibility and format evolution.
|
StringDataTypeInfo |
|
TimestampDataSerializer |
|
TimestampDataSerializer.TimestampDataSerializerSnapshot |
|
TimestampDataTypeInfo |
|
TypeCheckUtils |
Utils for type.
|