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