public class RowToProtoConverter extends Object
RowToProtoConverter
can convert flink row data to binary protobuf message data by codegen
process.Constructor and Description |
---|
RowToProtoConverter(RowType rowType,
PbFormatConfig formatConfig) |
Modifier and Type | Method and Description |
---|---|
byte[] |
convertRowToProtoBinary(RowData rowData) |
protected boolean |
isCodeSplit() |
public RowToProtoConverter(RowType rowType, PbFormatConfig formatConfig) throws PbCodegenException
PbCodegenException
public byte[] convertRowToProtoBinary(RowData rowData) throws Exception
Exception
@VisibleForTesting protected boolean isCodeSplit()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.