Created
March 27, 2018 06:31
-
-
Save kisimple/a183fd9c5ab14883eccdeda6a2a8cc9d to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 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(); | |
| } | |
| } | |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 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() { | |
| } | |
| } | |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment