public static class WindowJoin.MyJoinFunction extends Object implements JoinFunction<Tuple3<Long,String,Integer>,Tuple3<Long,String,Integer>,Tuple3<String,Integer,Integer>>
Constructor and Description |
---|
MyJoinFunction() |
public Tuple3<String,Integer,Integer> join(Tuple3<Long,String,Integer> first, Tuple3<Long,String,Integer> second) throws Exception
JoinFunction
join
in interface JoinFunction<Tuple3<Long,String,Integer>,Tuple3<Long,String,Integer>,Tuple3<String,Integer,Integer>>
first
- The element from first input.second
- The element from second input.Exception
- This method may throw exceptions. Throwing an exception will cause the operation
to fail and may trigger recovery.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.