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 |
---|---|
static PbCodegenDeserializer |
PbCodegenDeserializeFactory.getPbCodegenDes(com.google.protobuf.Descriptors.FieldDescriptor fd,
LogicalType type,
PbFormatContext formatContext) |
static PbCodegenDeserializer |
PbCodegenDeserializeFactory.getPbCodegenTopRowDes(com.google.protobuf.Descriptors.Descriptor descriptor,
RowType rowType,
PbFormatContext formatContext) |
Constructor and Description |
---|
PbCodegenArrayDeserializer(com.google.protobuf.Descriptors.FieldDescriptor fd,
LogicalType elementType,
PbFormatContext formatContext) |
PbCodegenMapDeserializer(com.google.protobuf.Descriptors.FieldDescriptor fd,
MapType mapType,
PbFormatContext formatContext) |
PbCodegenRowDeserializer(com.google.protobuf.Descriptors.Descriptor descriptor,
RowType rowType,
PbFormatContext formatContext) |
Modifier and Type | Method and Description |
---|---|
static PbCodegenSerializer |
PbCodegenSerializeFactory.getPbCodegenSer(com.google.protobuf.Descriptors.FieldDescriptor fd,
LogicalType type,
PbFormatContext formatContext) |
static PbCodegenSerializer |
PbCodegenSerializeFactory.getPbCodegenTopRowSer(com.google.protobuf.Descriptors.Descriptor descriptor,
RowType rowType,
PbFormatContext formatContext) |
Constructor and Description |
---|
PbCodegenArraySerializer(com.google.protobuf.Descriptors.FieldDescriptor fd,
LogicalType elementType,
PbFormatContext formatContext) |
PbCodegenMapSerializer(com.google.protobuf.Descriptors.FieldDescriptor fd,
MapType mapType,
PbFormatContext formatContext) |
PbCodegenRowSerializer(com.google.protobuf.Descriptors.Descriptor descriptor,
RowType rowType,
PbFormatContext formatContext) |
PbCodegenSimpleSerializer(com.google.protobuf.Descriptors.FieldDescriptor fd,
LogicalType type,
PbFormatContext formatContext) |
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.pbDefaultValueCode(com.google.protobuf.Descriptors.FieldDescriptor fieldDescriptor,
PbFormatContext pbFormatContext)
Get protobuf default value from
Descriptors.FieldDescriptor . |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.