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)

Method Summary

Modifier and Type	Method	Description
PbFormatConfig	getPbFormatConfig()
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)

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()