Class | Description |
---|---|
AbstractRowDataSerializer<T extends RowData> |
Row serializer, provided paged serialize paged method.
|
ArrayDataSerializer |
Serializer for
ArrayData . |
ArrayDataSerializer.ArrayDataSerializerSnapshot | |
BigDecimalTypeInfo | |
BinaryRowDataSerializer |
Serializer for
BinaryRowData . |
BinaryRowDataSerializer.BinaryRowDataSerializerSnapshot | |
DecimalDataSerializer |
Serializer for
DecimalData . |
DecimalDataSerializer.DecimalSerializerSnapshot | |
DecimalDataTypeInfo |
TypeInformation for
DecimalData . |
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 |
TypeSerializer of LogicalType for internal data structures. |
InternalTypeInfo<T> |
Type information that wraps a serializer that originated from a
LogicalType . |
LegacyInstantTypeInfo |
TypeInformation for Instant . |
LegacyLocalDateTimeTypeInfo | |
LegacyTimestampTypeInfo |
TypeInformation for Timestamp . |
LinkedListSerializer<T> |
A serializer for
LinkedList . |
LinkedListSerializer.LinkedListSerializerSnapshot<T> |
Snapshot class for the
LinkedListSerializer . |
MapDataSerializer |
Serializer for
MapData . |
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> |
Serializer for
RawValueData . |
RawValueDataSerializer.RawValueDataSerializerSnapshot<T> | |
RowDataSerializer |
Serializer for
RowData . |
RowDataSerializer.RowDataSerializerSnapshot | |
SortedMapSerializer<K,V> |
A serializer for
SortedMap . |
SortedMapSerializerSnapshot<K,V> |
Snapshot class for the
SortedMapSerializer . |
SortedMapTypeInfo<K,V> |
The type information for sorted maps.
|
StringDataSerializer |
Serializer for
StringData . |
StringDataSerializer.StringDataSerializerSnapshot |
Serializer configuration snapshot for compatibility and format evolution.
|
StringDataTypeInfo |
TypeInformation for
StringData . |
TimestampDataSerializer |
Serializer for
TimestampData . |
TimestampDataSerializer.TimestampDataSerializerSnapshot | |
TimestampDataTypeInfo |
TypeInformation for
TimestampData . |
TypeCheckUtils |
Utils for type.
|
WindowKeySerializer |
Serializer for
WindowKey which is composite with a BinaryRowData and a long
value. |
WindowKeySerializer.WindowKeySerializerSnapshot |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.