Class | Description |
---|---|
BaseArraySerializer |
A
TypeSerializer for BaseArray . |
BaseArraySerializer.BaseArraySerializerSnapshot | |
BaseMapSerializer |
A
TypeSerializer for BaseMap . |
BaseMapSerializer.BaseMapSerializerSnapshot | |
BaseRowSerializer |
A
TypeSerializer for BaseRow . |
BaseRowSerializer.BaseRowSerializerSnapshot | |
BigDecSerializer |
We create the BigDecSerializer instead of using the BigDecSerializer of flink-core module for
performance reasons in Python deserialization.
|
BigDecSerializer.BigDecSerializerSnapshot |
Serializer configuration snapshot for compatibility and format evolution.
|
DateSerializer |
Takes int instead of long as the serialized value.
|
DateSerializer.DateSerializerSnapshot |
Serializer configuration snapshot for compatibility and format evolution.
|
DecimalSerializer |
We create the DecimalSerializer instead of using the DecimalSerializer of flink-table-runtime-blink
for performance reasons in Python deserialization.
|
DecimalSerializer.DecimalSerializerSnapshot | |
StringSerializer |
We create the StringSerializer instead of using the StringSerializer of flink-core module
because the StringSerializer of flink-core module serialize every Char of String in serialize
method and deserialize the Char to build the String.
|
StringSerializer.StringSerializerSnapshot |
Serializer configuration snapshot for compatibility and format evolution.
|
TimeSerializer |
Uses int instead of long as the serialized value.
|
TimeSerializer.TimeSerializerSnapshot |
Serializer configuration snapshot for compatibility and format evolution.
|
TimestampSerializer |
Uses similar serialization/deserialization of SqlTimestampSerializer in blink to serialize Timestamp.
|
TimestampSerializer.TimestampSerializerSnapshot |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.