public interface PbCodegenDeserializer
PbCodegenDeserializer
is responsible for converting protobuf object to flink internal
object by codegen process. The codegen procedure could be considered as
returnVarName = codegen(pbStr)
Modifier and Type | Method and Description |
---|---|
String |
codegen(String resultVar,
String pbObjectCode,
int indent) |
String codegen(String resultVar, String pbObjectCode, int indent) throws PbCodegenException
resultVar
- the final var name that is calculated by codegen. This var name will be used
by outsider codegen environment. resultVariable
should be flink objectpbObjectCode
- may be a variable or expression. Current codegen environment can use this
literal name directly to access the input. pbObject
should be a protobuf objectPbCodegenException
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.