Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public class ExpressionReducer$6
- extends org.apache.flink.api.common.functions.RichMapFunction {
- transient org.apache.flink.types.Row out =
- new org.apache.flink.types.Row(1);
- public ExpressionReducer$6() throws Exception {
- }
- @Override
- public void open(org.apache.flink.configuration.Configuration parameters) throws Exception {
- }
- @Override
- public Object map(Object _in1) throws Exception {
- org.apache.flink.types.Row in1 = (org.apache.flink.types.Row) _in1;
- java.lang.String result$0 = "01,5,2013";
- boolean isNull$1 = false;
- java.lang.String result$2 = "%d,%m,%Y";
- boolean isNull$3 = false;
- boolean isNull$5 = isNull$1 || isNull$3;
- int result$4;
- if (isNull$5) {
- result$4 = -1;
- }
- else {
- result$4 =
- org.apache.flink.table.functions.utils.DateTimeFunctions.strToDate(result$0, result$2)
- ;
- }
- if (isNull$5) {
- out.setField(0, null);
- }
- else {
- out.setField(0, result$4);
- }
- return out;
- }
- @Override
- public void close() throws Exception {
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement