Package org.apache.flink.formats.protobuf.deserialize

Class PbCodegenDeserializeFactory

java.lang.Object

org.apache.flink.formats.protobuf.deserialize.PbCodegenDeserializeFactory

public class PbCodegenDeserializeFactory
extends Object

Codegen factory class which return PbCodegenDeserializer of different data type.

Constructor Summary

Constructors

Constructor	Description
PbCodegenDeserializeFactory()

Method Summary

Modifier and Type	Method	Description
static PbCodegenDeserializer	getPbCodegenDes(com.google.protobuf.Descriptors.FieldDescriptor fd, org.apache.flink.table.types.logical.LogicalType type, PbFormatContext formatContext)
static PbCodegenDeserializer	getPbCodegenTopRowDes(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

PbCodegenDeserializeFactory

public PbCodegenDeserializeFactory()

Method Detail

getPbCodegenDes

public static PbCodegenDeserializer getPbCodegenDes(com.google.protobuf.Descriptors.FieldDescriptor fd,
                                                    org.apache.flink.table.types.logical.LogicalType type,
                                                    PbFormatContext formatContext)
                                             throws PbCodegenException

Throws:

PbCodegenException

getPbCodegenTopRowDes

public static PbCodegenDeserializer getPbCodegenTopRowDes(com.google.protobuf.Descriptors.Descriptor descriptor,
                                                          org.apache.flink.table.types.logical.RowType rowType,
                                                          PbFormatContext formatContext)