org.apache.flink.formats.protobuf.deserialize

Class PbCodegenMapDeserializer

java.lang.Object

org.apache.flink.formats.protobuf.deserialize.PbCodegenMapDeserializer

All Implemented Interfaces:

PbCodegenDeserializer

public class PbCodegenMapDeserializer
extends Object
implements PbCodegenDeserializer

Deserializer to convert proto map type object to flink map type data.

Constructor Summary

Constructors

Constructor and Description
PbCodegenMapDeserializer(com.google.protobuf.Descriptors.FieldDescriptor fd, MapType mapType, PbFormatContext formatContext)

Method Summary

Modifier and Type	Method and Description
String	codegen(String resultVar, String pbObjectCode, int indent)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PbCodegenMapDeserializer

public PbCodegenMapDeserializer(com.google.protobuf.Descriptors.FieldDescriptor fd,
                                MapType mapType,
                                PbFormatContext formatContext)

Method Detail

codegen

public String codegen(String resultVar,
                      String pbObjectCode,
                      int indent)
               throws PbCodegenException

Specified by:

codegen in interface PbCodegenDeserializer

Parameters:

resultVar - the final var name that is calculated by codegen. This var name will be used by outsider codegen environment. resultVariable should be flink object

pbObjectCode - may be a variable or expression. Current codegen environment can use this literal name directly to access the input. pbObject should be a protobuf object

Returns:

The java code generated

Throws:

PbCodegenException