Class PbCodegenRowDeserializer

    • Constructor Detail

      • PbCodegenRowDeserializer

        public PbCodegenRowDeserializer​(com.google.protobuf.Descriptors.Descriptor descriptor,
                                        RowType rowType,
                                        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