Interface | Description |
---|---|
PbCodegenDeserializer |
PbCodegenDeserializer is responsible for converting protobuf object to flink internal
object by codegen process. |
Class | Description |
---|---|
PbCodegenArrayDeserializer |
Deserializer to convert proto array type object to flink array type data.
|
PbCodegenDeserializeFactory |
Codegen factory class which return
PbCodegenDeserializer of different data type. |
PbCodegenMapDeserializer |
Deserializer to convert proto map type object to flink map type data.
|
PbCodegenRowDeserializer |
Deserializer to convert proto message type object to flink row type data.
|
PbCodegenSimpleDeserializer |
Deserializer to convert proto simple type object to flink simple type data.
|
PbRowDataDeserializationSchema |
Deserialization schema from Protobuf to Flink types.
|
ProtoToRowConverter |
ProtoToRowConverter can convert binary protobuf message data to flink row data by codegen
process. |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.