@Internal public static final class CrossOperator.DefaultCrossFunction<T1,T2> extends Object implements CrossFunction<T1,T2,Tuple2<T1,T2>>
Constructor and Description |
---|
DefaultCrossFunction() |
public Tuple2<T1,T2> cross(T1 first, T2 second) throws Exception
CrossFunction
cross
in interface CrossFunction<T1,T2,Tuple2<T1,T2>>
first
- Element from first input.second
- Element from the second input.Exception
- The function may throw Exceptions, which will cause the program to cancel,
and may trigger the recovery logic.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.