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

Class RowToProtoConverter

java.lang.Object

org.apache.flink.formats.protobuf.serialize.RowToProtoConverter

public class RowToProtoConverter
extends Object

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

Constructor Summary

Constructors

Constructor	Description
RowToProtoConverter(org.apache.flink.table.types.logical.RowType rowType, PbFormatConfig formatConfig)

Method Summary

Modifier and Type	Method	Description
byte[]	convertRowToProtoBinary(org.apache.flink.table.data.RowData rowData)
protected boolean	isCodeSplit()

Methods inherited from class java.lang.Object

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

Constructor Detail

RowToProtoConverter

public RowToProtoConverter(org.apache.flink.table.types.logical.RowType rowType,
                           PbFormatConfig formatConfig)
                    throws PbCodegenException

Throws:

PbCodegenException

Method Detail

convertRowToProtoBinary

public byte[] convertRowToProtoBinary(org.apache.flink.table.data.RowData rowData)
                               throws Exception

Throws:

Exception

isCodeSplit

@VisibleForTesting
protected boolean isCodeSplit()