Package | Description |
---|---|
org.apache.flink.table.runtime.typeutils.serializers.python |
Class and Description |
---|
BigDecSerializer
We create the BigDecSerializer instead of using the BigDecSerializer of flink-core module for
performance reasons in Python deserialization.
|
DateSerializer
Takes int instead of long as the serialized value.
|
RowDataSerializer
A
TypeSerializer for RowData . |
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.
|
TimeSerializer
Uses int instead of long as the serialized value.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.