| PbCodegenArrayDeserializer |
Deserializer to convert proto array type object to flink array type data.
|
| PbCodegenDeserializeFactory |
|
| 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.
|