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

Class ProtoToRowConverter

java.lang.Object

org.apache.flink.formats.protobuf.deserialize.ProtoToRowConverter

public class ProtoToRowConverter
extends Object

ProtoToRowConverter can convert binary protobuf message data to flink row data by codegen process.

Constructor Summary

Constructors

Constructor	Description
ProtoToRowConverter(RowType rowType, PbFormatConfig formatConfig)

Method Summary

Modifier and Type	Method	Description
RowData	convertProtoBinaryToRow(byte[] data)
protected boolean	isCodeSplit()

Methods inherited from class java.lang.Object

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

Constructor Detail

ProtoToRowConverter

public ProtoToRowConverter(RowType rowType,
                           PbFormatConfig formatConfig)
                    throws PbCodegenException

Throws:

PbCodegenException

Method Detail

convertProtoBinaryToRow

public RowData convertProtoBinaryToRow(byte[] data)
                                throws Exception

Throws:

Exception

isCodeSplit

@VisibleForTesting
protected boolean isCodeSplit()