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–2020 The Apache Software Foundation. All rights reserved.