Advertisement
Guest User

Untitled

a guest
Jun 29th, 2017
66
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 1.37 KB | None | 0 0
  1.  
  2.       public class ExpressionReducer$6
  3.           extends org.apache.flink.api.common.functions.RichMapFunction {
  4.  
  5.  
  6.         transient org.apache.flink.types.Row out =
  7.             new org.apache.flink.types.Row(1);
  8.  
  9.  
  10.  
  11.         public ExpressionReducer$6() throws Exception {
  12.  
  13.  
  14.         }
  15.  
  16.  
  17.  
  18.  
  19.         @Override
  20.         public void open(org.apache.flink.configuration.Configuration parameters) throws Exception {
  21.          
  22.  
  23.         }
  24.  
  25.         @Override
  26.         public Object map(Object _in1) throws Exception {
  27.           org.apache.flink.types.Row in1 = (org.apache.flink.types.Row) _in1;
  28.  
  29.  
  30.  
  31.  
  32.  
  33.  
  34.  
  35.  
  36.           java.lang.String result$0 = "01,5,2013";
  37.           boolean isNull$1 = false;
  38.  
  39.  
  40.           java.lang.String result$2 = "%d,%m,%Y";
  41.           boolean isNull$3 = false;
  42.  
  43.           boolean isNull$5 = isNull$1 || isNull$3;
  44.           int result$4;
  45.           if (isNull$5) {
  46.             result$4 = -1;
  47.           }
  48.           else {
  49.             result$4 =
  50.           org.apache.flink.table.functions.utils.DateTimeFunctions.strToDate(result$0, result$2)
  51.           ;
  52.           }
  53.  
  54.           if (isNull$5) {
  55.             out.setField(0, null);
  56.           }
  57.           else {
  58.             out.setField(0, result$4);
  59.           }
  60.  
  61.           return out;
  62.  
  63.         }
  64.  
  65.         @Override
  66.         public void close() throws Exception {
  67.  
  68.  
  69.         }
  70.       }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement