Interface PbCodegenSerializer
-
- All Known Implementing Classes:
PbCodegenArraySerializer,PbCodegenMapSerializer,PbCodegenRowSerializer,PbCodegenSimpleSerializer
public interface PbCodegenSerializerPbCodegenSerializeris responsible for converting flink internal data object to protobuf object by codegen process. The codegen procedure could be considered asresultVariableCode = codegen(flinkObjectCode)
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Stringcodegen(String resultVar, String flinkObjectCode, int indent)
-
-
-
Method Detail
-
codegen
String codegen(String resultVar, String flinkObjectCode, int indent) throws PbCodegenException
- Parameters:
resultVar- the final var name that is calculated by codegen. This var name will be used by outsider codegen environment.resultVariableshould be protobuf objectflinkObjectCode- may be a variable or expression. Current codegen environment can use this literal name directly to access the input.flinkObjectshould be a flink internal object.- Returns:
- The java code generated
- Throws:
PbCodegenException
-
-