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 and Description
RowToProtoConverter(RowType rowType, PbFormatConfig formatConfig)

Method Summary

Modifier and Type	Method and Description
byte[]	convertRowToProtoBinary(RowData rowData)

Methods inherited from class java.lang.Object

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

Constructor Detail

RowToProtoConverter

public RowToProtoConverter(RowType rowType,
                           PbFormatConfig formatConfig)
                    throws PbCodegenException

Throws:

PbCodegenException

Method Detail

convertRowToProtoBinary

public byte[] convertRowToProtoBinary(RowData rowData)
                               throws Exception

Throws:

Exception