org.apache.flink.formats.protobuf.deserialize

Class PbCodegenArrayDeserializer

java.lang.Object

org.apache.flink.formats.protobuf.deserialize.PbCodegenArrayDeserializer

All Implemented Interfaces:

PbCodegenDeserializer

public class PbCodegenArrayDeserializer
extends Object
implements PbCodegenDeserializer

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

Constructor Summary

Constructors

Constructor and Description
PbCodegenArrayDeserializer(com.google.protobuf.Descriptors.FieldDescriptor fd, LogicalType elementType, 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

PbCodegenArrayDeserializer

public PbCodegenArrayDeserializer(com.google.protobuf.Descriptors.FieldDescriptor fd,
                                  LogicalType elementType,
                                  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