Uses of Class
org.apache.flink.formats.protobuf.PbFormatContext
-
Packages that use PbFormatContext Package Description org.apache.flink.formats.protobuf.deserialize org.apache.flink.formats.protobuf.serialize org.apache.flink.formats.protobuf.util -
-
Uses of PbFormatContext in org.apache.flink.formats.protobuf.deserialize
Methods in org.apache.flink.formats.protobuf.deserialize with parameters of type PbFormatContext Modifier and Type Method Description static PbCodegenDeserializerPbCodegenDeserializeFactory. getPbCodegenDes(com.google.protobuf.Descriptors.FieldDescriptor fd, org.apache.flink.table.types.logical.LogicalType type, PbFormatContext formatContext)static PbCodegenDeserializerPbCodegenDeserializeFactory. getPbCodegenTopRowDes(com.google.protobuf.Descriptors.Descriptor descriptor, org.apache.flink.table.types.logical.RowType rowType, PbFormatContext formatContext)Constructors in org.apache.flink.formats.protobuf.deserialize with parameters of type PbFormatContext Constructor Description PbCodegenArrayDeserializer(com.google.protobuf.Descriptors.FieldDescriptor fd, org.apache.flink.table.types.logical.LogicalType elementType, PbFormatContext formatContext)PbCodegenMapDeserializer(com.google.protobuf.Descriptors.FieldDescriptor fd, org.apache.flink.table.types.logical.MapType mapType, PbFormatContext formatContext)PbCodegenRowDeserializer(com.google.protobuf.Descriptors.Descriptor descriptor, org.apache.flink.table.types.logical.RowType rowType, PbFormatContext formatContext) -
Uses of PbFormatContext in org.apache.flink.formats.protobuf.serialize
Methods in org.apache.flink.formats.protobuf.serialize with parameters of type PbFormatContext Modifier and Type Method Description static PbCodegenSerializerPbCodegenSerializeFactory. getPbCodegenSer(com.google.protobuf.Descriptors.FieldDescriptor fd, org.apache.flink.table.types.logical.LogicalType type, PbFormatContext formatContext)static PbCodegenSerializerPbCodegenSerializeFactory. getPbCodegenTopRowSer(com.google.protobuf.Descriptors.Descriptor descriptor, org.apache.flink.table.types.logical.RowType rowType, PbFormatContext formatContext)Constructors in org.apache.flink.formats.protobuf.serialize with parameters of type PbFormatContext Constructor Description PbCodegenArraySerializer(com.google.protobuf.Descriptors.FieldDescriptor fd, org.apache.flink.table.types.logical.LogicalType elementType, PbFormatContext formatContext)PbCodegenMapSerializer(com.google.protobuf.Descriptors.FieldDescriptor fd, org.apache.flink.table.types.logical.MapType mapType, PbFormatContext formatContext)PbCodegenRowSerializer(com.google.protobuf.Descriptors.Descriptor descriptor, org.apache.flink.table.types.logical.RowType rowType, PbFormatContext formatContext)PbCodegenSimpleSerializer(com.google.protobuf.Descriptors.FieldDescriptor fd, org.apache.flink.table.types.logical.LogicalType type, PbFormatContext formatContext) -
Uses of PbFormatContext in org.apache.flink.formats.protobuf.util
Methods in org.apache.flink.formats.protobuf.util with parameters of type PbFormatContext Modifier and Type Method Description static StringPbCodegenUtils. 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 StringPbCodegenUtils. pbDefaultValueCode(com.google.protobuf.Descriptors.FieldDescriptor fieldDescriptor, PbFormatContext pbFormatContext)Get protobuf default value fromDescriptors.FieldDescriptor.
-