Package | Description |
---|---|
org.apache.flink.formats.protobuf.deserialize |
Modifier and Type | Class and Description |
---|---|
class |
PbCodegenArrayDeserializer
Deserializer to convert proto array type object to flink array type data.
|
class |
PbCodegenMapDeserializer
Deserializer to convert proto map type object to flink map type data.
|
class |
PbCodegenRowDeserializer
Deserializer to convert proto message type object to flink row type data.
|
class |
PbCodegenSimpleDeserializer
Deserializer to convert proto simple type object to flink simple type data.
|
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) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.