Package | Description |
---|---|
org.apache.flink.formats.protobuf.deserialize | |
org.apache.flink.formats.protobuf.serialize | |
org.apache.flink.formats.protobuf.util |
Modifier and Type | Method and Description |
---|---|
String |
PbCodegenArrayDeserializer.codegen(String resultVar,
String pbObjectCode,
int indent) |
String |
PbCodegenDeserializer.codegen(String resultVar,
String pbObjectCode,
int indent) |
String |
PbCodegenRowDeserializer.codegen(String resultVar,
String pbObjectCode,
int indent) |
String |
PbCodegenSimpleDeserializer.codegen(String resultVar,
String pbObjectCode,
int indent) |
String |
PbCodegenMapDeserializer.codegen(String resultVar,
String pbObjectCode,
int indent) |
static PbCodegenDeserializer |
PbCodegenDeserializeFactory.getPbCodegenDes(com.google.protobuf.Descriptors.FieldDescriptor fd,
LogicalType type,
PbFormatContext formatContext) |
Constructor and Description |
---|
ProtoToRowConverter(RowType rowType,
PbFormatConfig formatConfig) |
Modifier and Type | Method and Description |
---|---|
String |
PbCodegenRowSerializer.codegen(String resultVar,
String flinkObjectCode,
int indent) |
String |
PbCodegenArraySerializer.codegen(String resultVar,
String flinkObjectCode,
int indent) |
String |
PbCodegenSimpleSerializer.codegen(String resultVar,
String flinkObjectCode,
int indent) |
String |
PbCodegenSerializer.codegen(String resultVar,
String flinkObjectCode,
int indent) |
String |
PbCodegenMapSerializer.codegen(String resultVar,
String flinkObjectCode,
int indent) |
static PbCodegenSerializer |
PbCodegenSerializeFactory.getPbCodegenSer(com.google.protobuf.Descriptors.FieldDescriptor fd,
LogicalType type,
PbFormatContext formatContext) |
Constructor and Description |
---|
RowToProtoConverter(RowType rowType,
PbFormatConfig formatConfig) |
Modifier and Type | Method and Description |
---|---|
static String |
PbCodegenUtils.convertFlinkArrayElementToPbWithDefaultValueCode(String flinkArrDataVar,
String iVar,
String resultPbVar,
com.google.protobuf.Descriptors.FieldDescriptor elementPbFd,
LogicalType elementDataType,
PbFormatContext pbFormatContext,
int indent)
This method will be called from serializer of flink array/map type because flink contains
both array/map type in array format.
|
static String |
PbCodegenUtils.getTypeStrFromProto(com.google.protobuf.Descriptors.FieldDescriptor fd,
boolean isList,
String outerPrefix)
Get java type str from
Descriptors.FieldDescriptor which directly fetched from protobuf object. |
static String |
PbCodegenUtils.pbDefaultValueCode(com.google.protobuf.Descriptors.FieldDescriptor fieldDescriptor,
PbFormatContext pbFormatContext)
Get protobuf default value from
Descriptors.FieldDescriptor . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.