Package | Description |
---|---|
org.apache.flink.table.runtime.typeutils.serializers.python |
Class and Description |
---|
BaseRowSerializer
A
TypeSerializer for BaseRow . |
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.
|
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–2020 The Apache Software Foundation. All rights reserved.