@Internal public class SelectByMaxFunction<T extends Tuple> extends Object implements ReduceFunction<T>
Constructor and Description |
---|
SelectByMaxFunction(TupleTypeInfo<T> type,
int... fields)
Constructor which is overwriting the default constructor.
|
Modifier and Type | Method and Description |
---|---|
T |
reduce(T value1,
T value2)
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
reduce
in interface 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–2017 The Apache Software Foundation. All rights reserved.