Class PbCodegenSerializeFactory
- java.lang.Object
-
- org.apache.flink.formats.protobuf.serialize.PbCodegenSerializeFactory
-
public class PbCodegenSerializeFactory extends Object
Codegen factory class which returnPbCodegenSerializerof different data type.
-
-
Constructor Summary
Constructors Constructor Description PbCodegenSerializeFactory()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static PbCodegenSerializergetPbCodegenSer(com.google.protobuf.Descriptors.FieldDescriptor fd, org.apache.flink.table.types.logical.LogicalType type, PbFormatContext formatContext)static PbCodegenSerializergetPbCodegenTopRowSer(com.google.protobuf.Descriptors.Descriptor descriptor, org.apache.flink.table.types.logical.RowType rowType, PbFormatContext formatContext)
-
-
-
Method Detail
-
getPbCodegenSer
public static PbCodegenSerializer getPbCodegenSer(com.google.protobuf.Descriptors.FieldDescriptor fd, org.apache.flink.table.types.logical.LogicalType type, PbFormatContext formatContext) throws PbCodegenException
- Throws:
PbCodegenException
-
getPbCodegenTopRowSer
public static PbCodegenSerializer getPbCodegenTopRowSer(com.google.protobuf.Descriptors.Descriptor descriptor, org.apache.flink.table.types.logical.RowType rowType, PbFormatContext formatContext)
-
-