Interface | Description |
---|---|
PbCodegenSerializer |
PbCodegenSerializer is responsible for converting flink internal data object to protobuf
object by codegen process. |
Class | Description |
---|---|
PbCodegenArraySerializer |
Serializer to convert flink array type data to proto array type object.
|
PbCodegenMapSerializer |
Serializer to convert flink map type data to proto map type object.
|
PbCodegenRowSerializer |
Serializer to convert flink row type data to proto row type object.
|
PbCodegenSerializeFactory |
Codegen factory class which return
PbCodegenSerializer of different data type. |
PbCodegenSimpleSerializer |
Serializer to convert flink simple type data to proto simple type object.
|
PbRowDataSerializationSchema |
Serialization schema from Flink to Protobuf types.
|
RowToProtoConverter |
RowToProtoConverter can convert flink row data to binary protobuf message data by codegen
process. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.