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 |
|
LinkedListSerializer<T> |
|
LinkedListSerializer.LinkedListSerializerSnapshot<T> |
|
MapDataSerializer |
|
MapDataSerializer.MapDataSerializerSnapshot |
|
PagedTypeSerializer<T> |
A type serializer which provides paged serialize and deserialize methods.
|
PythonTypeUtils |
Utilities for converting Flink logical types, such as convert it to the related TypeSerializer or
ProtoType.
|
PythonTypeUtils.ArrayDataConverter<T> |
The element in the Object Array will be converted to the corresponding Data through element
DataConverter.
|
PythonTypeUtils.ByteDataConverter |
Python Long will be converted to Long in PemJa, so we need ByteDataConverter to convert Java
Long to internal Byte.
|
PythonTypeUtils.DataConverter<IN,INTER,OUT> |
Data Converter that converts the data to the java format data which can be used in PemJa.
|
PythonTypeUtils.FloatDataConverter |
Python Float will be converted to Double in PemJa, so we need FloatDataConverter to convert
Java Double to internal Float.
|
PythonTypeUtils.IdentityDataConverter<IN,OUT> |
Identity data converter.
|
PythonTypeUtils.IntDataConverter |
Python Long will be converted to Long in PemJa, so we need IntDataConverter to convert Java
Long to internal Integer.
|
PythonTypeUtils.LogicalTypeToProtoTypeConverter |
Converter That convert the logicalType to the related Prototype.
|
PythonTypeUtils.MapDataConverter |
The key/value in the Map will be converted to the corresponding Data through key/value
DataConverter.
|
PythonTypeUtils.RowDataConverter |
RowData will be converted to the Object Array [RowKind(as Long Object), Field Values(as
Object Array)].
|
PythonTypeUtils.ShortDataConverter |
Python Long will be converted to Long in PemJa, so we need ShortDataConverter to convert Java
Long to internal Short.
|
PythonTypeUtils.TimeDataConverter |
Python datetime.time will be converted to Time in PemJa, so we need TimeDataConverter to
convert Java Double to internal Integer.
|
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.
|
WindowKeySerializer |
|
WindowKeySerializer.WindowKeySerializerSnapshot |
|