Package org.apache.flink.formats.protobuf.serialize

Class PbCodegenSerializeFactory

java.lang.Object

org.apache.flink.formats.protobuf.serialize.PbCodegenSerializeFactory

public class PbCodegenSerializeFactory
extends Object

Codegen factory class which return PbCodegenSerializer of different data type.

Constructor Summary

Constructors

Constructor	Description
PbCodegenSerializeFactory()

Method Summary

Modifier and Type	Method	Description
static PbCodegenSerializer	getPbCodegenSer(com.google.protobuf.Descriptors.FieldDescriptor fd, org.apache.flink.table.types.logical.LogicalType type, PbFormatContext formatContext)
static PbCodegenSerializer	getPbCodegenTopRowSer(com.google.protobuf.Descriptors.Descriptor descriptor, org.apache.flink.table.types.logical.RowType rowType, PbFormatContext formatContext)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PbCodegenSerializeFactory

public PbCodegenSerializeFactory()

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)