Package org.apache.flink.formats.protobuf

Class PbFormatContext

java.lang.Object

org.apache.flink.formats.protobuf.PbFormatContext

public class PbFormatContext
extends Object

store config and common information.

Constructor Summary

Constructors

Constructor	Description
PbFormatContext(PbFormatConfig pbFormatConfig, boolean readDefaultValuesForPrimitiveTypes)

Method Summary

Modifier and Type	Method	Description
PbFormatConfig	getPbFormatConfig()
boolean	getReadDefaultValuesForPrimitiveTypes()
List<String>	getSplitMethodStack()
String	splitDeserializerRowTypeMethod(String rowDataVar, String messageTypeStr, String messageTypeVar, String code)
String	splitSerializerRowTypeMethod(String rowDataVar, String messageTypeStr, String messageTypeVar, String code)

Methods inherited from class java.lang.Object

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

Constructor Detail

PbFormatContext

public PbFormatContext(PbFormatConfig pbFormatConfig,
                       boolean readDefaultValuesForPrimitiveTypes)

Method Detail

splitDeserializerRowTypeMethod

public String splitDeserializerRowTypeMethod(String rowDataVar,
                                             String messageTypeStr,
                                             String messageTypeVar,
                                             String code)

splitSerializerRowTypeMethod

public String splitSerializerRowTypeMethod(String rowDataVar,
                                           String messageTypeStr,
                                           String messageTypeVar,
                                           String code)

getSplitMethodStack

public List<String> getSplitMethodStack()

getPbFormatConfig

public PbFormatConfig getPbFormatConfig()

getReadDefaultValuesForPrimitiveTypes

public boolean getReadDefaultValuesForPrimitiveTypes()