All Classes

Class	Description
PbCodegenAppender	Helper class which do code fragment concat.
PbCodegenArrayDeserializer	Deserializer to convert proto array type object to flink array type data.
PbCodegenArraySerializer	Serializer to convert flink array type data to proto array type object.
PbCodegenDeserializeFactory	Codegen factory class which return PbCodegenDeserializer of different data type.
PbCodegenDeserializer	PbCodegenDeserializer is responsible for converting protobuf object to flink internal object by codegen process.
PbCodegenException	Exception represents codegen error in row and proto conversion which is probably a bug.
PbCodegenMapDeserializer	Deserializer to convert proto map type object to flink map type data.
PbCodegenMapSerializer	Serializer to convert flink map type data to proto map type object.
PbCodegenRowDeserializer	Deserializer to convert proto message type object to flink row type data.
PbCodegenRowSerializer	Serializer to convert flink row type data to proto row type object.
PbCodegenSerializeFactory	Codegen factory class which return PbCodegenSerializer of different data type.
PbCodegenSerializer	PbCodegenSerializer is responsible for converting flink internal data object to protobuf object by codegen process.
PbCodegenSimpleDeserializer	Deserializer to convert proto simple type object to flink simple type data.
PbCodegenSimpleSerializer	Serializer to convert flink simple type data to proto simple type object.
PbCodegenUtils	Codegen utils only used in protobuf format.
PbCodegenVarId	Singleton class for generating variable suffix number globally to avoid conflict in codegen sections.
PbConstant	Keeps protobuf constants separately.
PbDecodingFormat	DecodingFormat for protobuf decoding.
PbEncodingFormat	EncodingFormat for protobuf encoding.
PbFileFormatFactory	Throw a ValidationException when using Protobuf format factory for file system.
PbFormatConfig	Config of protobuf configs.
PbFormatConfig.PbFormatConfigBuilder	Builder of PbFormatConfig.
PbFormatContext	store config and common information.
PbFormatFactory	Table format factory for providing configured instances of Protobuf to RowData SerializationSchema and DeserializationSchema.
PbFormatOptions	This class holds configuration constants used by protobuf format.
PbFormatUtils	Protobuf function util.
PbRowDataDeserializationSchema	Deserialization schema from Protobuf to Flink types.
PbRowDataSerializationSchema	Serialization schema from Flink to Protobuf types.
PbSchemaValidationUtils	Validation class to verify protobuf definition and flink schema.
PbToRowTypeUtil	Generate Row type information according to pb descriptors.
ProtobufInternalUtils	This class is to access internal method in protobuf package.
ProtoToRowConverter	ProtoToRowConverter can convert binary protobuf message data to flink row data by codegen process.
RowToProtoConverter	RowToProtoConverter can convert flink row data to binary protobuf message data by codegen process.