org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer, java.lang.Integer> to org.apache.flink.streaming.api.StreamEdge