org.apache.flink.types.Record to org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer, java.lang.Integer>