DataStreamCorrelateFunction.java

      public class DataStreamCorrelateRule$20
          extends org.apache.flink.streaming.api.functions.ProcessFunction {

        final org.apache.flink.table.runtime.TableFunctionCollector instance_org$apache$flink$table$runtime$TableFunctionCollector$15;
        
        final org.apache.flink.table.examples.scala.UDTFExample.Func0 function_org$apache$flink$table$examples$scala$UDTFExample$Func0$16ea6ef48e35886045c180780a1a0914;
        
        

        public DataStreamCorrelateRule$20() throws Exception {
          
          function_org$apache$flink$table$examples$scala$UDTFExample$Func0$16ea6ef48e35886045c180780a1a0914 = (org.apache.flink.table.examples.scala.UDTFExample.Func0)
          org.apache.flink.table.functions.utils.UserDefinedFunctionUtils
          .deserialize("rO0ABXNyADdvcmcuYXBhY2hlLmZsaW5rLnRhYmxlLmV4YW1wbGVzLnNjYWxhLlVEVEZFeGFtcGxlJEZ1bmMwx7gRE9A3qxQCAAB4cgAub3JnLmFwYWNoZS5mbGluay50YWJsZS5mdW5jdGlvbnMuVGFibGVGdW5jdGlvbitDWoCPi2zTAgABTAAJY29sbGVjdG9ydAAhTG9yZy9hcGFjaGUvZmxpbmsvdXRpbC9Db2xsZWN0b3I7eHIANG9yZy5hcGFjaGUuZmxpbmsudGFibGUuZnVuY3Rpb25zLlVzZXJEZWZpbmVkRnVuY3Rpb27pK9ozWzdu7AIAAHhwcA");
                 
          
        }

        
        public DataStreamCorrelateRule$20(org.apache.flink.table.runtime.TableFunctionCollector arg0) throws Exception {
          this();
          instance_org$apache$flink$table$runtime$TableFunctionCollector$15 = arg0;
        
        }
        
        

        @Override
        public void open(org.apache.flink.configuration.Configuration parameters) throws Exception {
          
          function_org$apache$flink$table$examples$scala$UDTFExample$Func0$16ea6ef48e35886045c180780a1a0914.open(new org.apache.flink.table.functions.FunctionContext(getRuntimeContext()));
                 
          
        }

        @Override
        public void processElement(Object _in1, org.apache.flink.streaming.api.functions.ProcessFunction.Context ctx,org.apache.flink.util.Collector c) throws Exception {
          org.apache.flink.types.Row in1 = (org.apache.flink.types.Row) _in1;
          
          
          
          boolean isNull$12 = (java.lang.Integer) in1.getField(2) == null;
          int result$11;
          if (isNull$12) {
            result$11 = -1;
          }
          else {
            result$11 = (java.lang.Integer) in1.getField(2);
          }
          
          
          boolean isNull$8 = (java.lang.Long) in1.getField(0) == null;
          long result$7;
          if (isNull$8) {
            result$7 = -1L;
          }
          else {
            result$7 = (java.lang.Long) in1.getField(0);
          }
          
          
          boolean isNull$10 = (java.lang.String) in1.getField(1) == null;
          java.lang.String result$9;
          if (isNull$10) {
            result$9 = "";
          }
          else {
            result$9 = (java.lang.String) (java.lang.String) in1.getField(1);
          }
          
          
          
          function_org$apache$flink$table$examples$scala$UDTFExample$Func0$16ea6ef48e35886045c180780a1a0914.setCollector(instance_org$apache$flink$table$runtime$TableFunctionCollector$15);
          
          
          
          long result$18;
          boolean isNull$19;
          if (false) {
            result$18 = -1L;
            isNull$19 = true;
          }
          else {
            
          boolean isNull$17 = (java.lang.Long) in1.getField(0) == null;
          long result$16;
          if (isNull$17) {
            result$16 = -1L;
          }
          else {
            result$16 = (java.lang.Long) in1.getField(0);
          }
          
            result$18 = result$16;
            isNull$19 = isNull$17;
          }
          
          function_org$apache$flink$table$examples$scala$UDTFExample$Func0$16ea6ef48e35886045c180780a1a0914.eval(result$18);
          
          
        }

        @Override
        public void close() throws Exception {
          
          function_org$apache$flink$table$examples$scala$UDTFExample$Func0$16ea6ef48e35886045c180780a1a0914.close();
                 
          
        }
      }
    

TableFunctionCollector.java

      public class TableFunctionCollector$29 extends org.apache.flink.table.runtime.TableFunctionCollector {

        
        final org.apache.flink.types.Row out =
            new org.apache.flink.types.Row(4);
        
        

        public TableFunctionCollector$29() throws Exception {
          
          
        }

        @Override
        public void collect(Object record) throws Exception {
          super.collect(record);
          org.apache.flink.types.Row in1 = (org.apache.flink.types.Row) getInput();
          java.lang.Long in2 = (java.lang.Long) record;
          
          boolean isNull$26 = (java.lang.Integer) in1.getField(2) == null;
          int result$25;
          if (isNull$26) {
            result$25 = -1;
          }
          else {
            result$25 = (java.lang.Integer) in1.getField(2);
          }
          
          
          boolean isNull$22 = (java.lang.Long) in1.getField(0) == null;
          long result$21;
          if (isNull$22) {
            result$21 = -1L;
          }
          else {
            result$21 = (java.lang.Long) in1.getField(0);
          }
          
          
          boolean isNull$24 = (java.lang.String) in1.getField(1) == null;
          java.lang.String result$23;
          if (isNull$24) {
            result$23 = "";
          }
          else {
            result$23 = (java.lang.String) (java.lang.String) in1.getField(1);
          }
          
          
          
          
          
          if (isNull$22) {
            out.setField(0, null);
          }
          else {
            out.setField(0, result$21);
          }
          
          
          
          if (isNull$24) {
            out.setField(1, null);
          }
          else {
            out.setField(1, result$23);
          }
          
          
          
          if (isNull$26) {
            out.setField(2, null);
          }
          else {
            out.setField(2, result$25);
          }
          
          
          
          boolean isNull$28 = (java.lang.Long) in2 == null;
          long result$27;
          if (isNull$28) {
            result$27 = -1L;
          }
          else {
            result$27 = (java.lang.Long) in2;
          }
          
          if (isNull$28) {
            out.setField(3, null);
          }
          else {
            out.setField(3, result$27);
          }
          
          getCollector().collect(out);
          
        }

        @Override
        public void close() {
        }
      }