Uses of Class
org.apache.flink.formats.protobuf.PbCodegenException

Packages that use PbCodegenException

Package	Description
org.apache.flink.formats.protobuf.deserialize
org.apache.flink.formats.protobuf.serialize
org.apache.flink.formats.protobuf.util

Uses of PbCodegenException in org.apache.flink.formats.protobuf.deserialize

Methods in org.apache.flink.formats.protobuf.deserialize that throw PbCodegenException

Modifier and Type	Method	Description
String	PbCodegenArrayDeserializer.codegen(String resultVar, String pbObjectCode, int indent)
String	PbCodegenDeserializer.codegen(String resultVar, String pbObjectCode, int indent)
String	PbCodegenMapDeserializer.codegen(String resultVar, String pbObjectCode, int indent)
String	PbCodegenRowDeserializer.codegen(String resultVar, String pbObjectCode, int indent)
String	PbCodegenSimpleDeserializer.codegen(String resultVar, String pbObjectCode, int indent)
static PbCodegenDeserializer	PbCodegenDeserializeFactory.getPbCodegenDes(com.google.protobuf.Descriptors.FieldDescriptor fd, org.apache.flink.table.types.logical.LogicalType type, PbFormatContext formatContext)

Constructors in org.apache.flink.formats.protobuf.deserialize that throw PbCodegenException

Constructor	Description
ProtoToRowConverter(org.apache.flink.table.types.logical.RowType rowType, PbFormatConfig formatConfig)

Uses of PbCodegenException in org.apache.flink.formats.protobuf.serialize

Methods in org.apache.flink.formats.protobuf.serialize that throw PbCodegenException

Modifier and Type	Method	Description
String	PbCodegenArraySerializer.codegen(String resultVar, String flinkObjectCode, int indent)
String	PbCodegenMapSerializer.codegen(String resultVar, String flinkObjectCode, int indent)
String	PbCodegenRowSerializer.codegen(String resultVar, String flinkObjectCode, int indent)
String	PbCodegenSerializer.codegen(String resultVar, String flinkObjectCode, int indent)
String	PbCodegenSimpleSerializer.codegen(String resultVar, String flinkObjectCode, int indent)
static PbCodegenSerializer	PbCodegenSerializeFactory.getPbCodegenSer(com.google.protobuf.Descriptors.FieldDescriptor fd, org.apache.flink.table.types.logical.LogicalType type, PbFormatContext formatContext)

Constructors in org.apache.flink.formats.protobuf.serialize that throw PbCodegenException

Constructor	Description
RowToProtoConverter(org.apache.flink.table.types.logical.RowType rowType, PbFormatConfig formatConfig)

Uses of PbCodegenException in org.apache.flink.formats.protobuf.util

Methods in org.apache.flink.formats.protobuf.util that throw PbCodegenException

Modifier and Type	Method	Description
static String	PbCodegenUtils.convertFlinkArrayElementToPbWithDefaultValueCode(String flinkArrDataVar, String iVar, String resultPbVar, com.google.protobuf.Descriptors.FieldDescriptor elementPbFd, org.apache.flink.table.types.logical.LogicalType elementDataType, PbFormatContext pbFormatContext, int indent)	This method will be called from serializer of flink array/map type because flink contains both array/map type in array format.
static String	PbCodegenUtils.getTypeStrFromProto(com.google.protobuf.Descriptors.FieldDescriptor fd, boolean isList)	Get java type str from Descriptors.FieldDescriptor which directly fetched from protobuf object.
static String	PbCodegenUtils.pbDefaultValueCode(com.google.protobuf.Descriptors.FieldDescriptor fieldDescriptor, PbFormatContext pbFormatContext)	Get protobuf default value from Descriptors.FieldDescriptor.