@Internal public class SelectByMaxFunction<T extends Tuple> extends Object implements ReduceFunction<T>
|Constructor and Description|
Constructor which is overwriting the default constructor.
|Modifier and Type||Method and Description|
Reduce implementation, returns bigger tuple or value1 if both tuples are equal.
public SelectByMaxFunction(TupleTypeInfo<T> type, int... fields)
type- Types of tuple whether to check if given fields are key types.
fields- Array of integers which are used as key for comparison. The order of indexes is regarded in the reduce function. First index has highest priority and last index has least priority.
public T reduce(T value1, T value2) throws Exception
ReduceFunction<T extends Tuple>
value1- The first value to combine.
value2- The second value to combine.
Exception- This method may throw exceptions. Throwing an exception will cause the operation to fail and may trigger recovery.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.