public static class IterateExample.InputMap extends Object implements MapFunction<Tuple2<Integer,Integer>,Tuple5<Integer,Integer,Integer,Integer,Integer>>
public Tuple5<Integer,Integer,Integer,Integer,Integer> map(Tuple2<Integer,Integer> value) throws Exception
MapFunction
map
in interface MapFunction<Tuple2<Integer,Integer>,Tuple5<Integer,Integer,Integer,Integer,Integer>>
value
- The input value.Exception
- This method may throw exceptions. Throwing an exception will cause the
operation to fail and may trigger recovery.Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.