public class ExtremumOperator<T extends java.lang.Comparable<T>> extends java.lang.Object implements IMultisetAggregationOperator<T,java.util.SortedMap<T,java.lang.Integer>,T>
| Modifier and Type | Class and Description |
|---|---|
static class |
ExtremumOperator.Extreme |
| Modifier and Type | Method and Description |
|---|---|
T |
aggregateStream(java.util.stream.Stream<T> stream)
Calculates the aggregate results from a given stream of values; all values are considered as inserted
|
java.util.SortedMap<T,java.lang.Integer> |
clone(java.util.SortedMap<T,java.lang.Integer> original)
Clones the given accumulator (with all its internal contents).
|
java.util.SortedMap<T,java.lang.Integer> |
createNeutral() |
T |
getAggregate(java.util.SortedMap<T,java.lang.Integer> result) |
static <T extends java.lang.Comparable<T>> |
getMax() |
static <T extends java.lang.Comparable<T>> |
getMin() |
java.lang.String |
getName()
A name or identifier of the operator.
|
java.lang.String |
getShortDescription()
A textual description of the operator.
|
boolean |
isNeutral(java.util.SortedMap<T,java.lang.Integer> result) |
java.util.SortedMap<T,java.lang.Integer> |
update(java.util.SortedMap<T,java.lang.Integer> oldResult,
T updateValue,
boolean isInsertion) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitcombine, contains, prettyPrintpublic static <T extends java.lang.Comparable<T>> ExtremumOperator<T> getMin()
public static <T extends java.lang.Comparable<T>> ExtremumOperator<T> getMax()
public java.lang.String getShortDescription()
IMultisetAggregationOperatorgetShortDescription in interface IMultisetAggregationOperator<T extends java.lang.Comparable<T>,java.util.SortedMap<T extends java.lang.Comparable<T>,java.lang.Integer>,T extends java.lang.Comparable<T>>public java.lang.String getName()
IMultisetAggregationOperatorpublic java.util.SortedMap<T,java.lang.Integer> createNeutral()
createNeutral in interface IMultisetAggregationOperator<T extends java.lang.Comparable<T>,java.util.SortedMap<T extends java.lang.Comparable<T>,java.lang.Integer>,T extends java.lang.Comparable<T>>public boolean isNeutral(java.util.SortedMap<T,java.lang.Integer> result)
isNeutral in interface IMultisetAggregationOperator<T extends java.lang.Comparable<T>,java.util.SortedMap<T extends java.lang.Comparable<T>,java.lang.Integer>,T extends java.lang.Comparable<T>>public java.util.SortedMap<T,java.lang.Integer> update(java.util.SortedMap<T,java.lang.Integer> oldResult, T updateValue, boolean isInsertion)
update in interface IMultisetAggregationOperator<T extends java.lang.Comparable<T>,java.util.SortedMap<T extends java.lang.Comparable<T>,java.lang.Integer>,T extends java.lang.Comparable<T>>public T getAggregate(java.util.SortedMap<T,java.lang.Integer> result)
getAggregate in interface IMultisetAggregationOperator<T extends java.lang.Comparable<T>,java.util.SortedMap<T extends java.lang.Comparable<T>,java.lang.Integer>,T extends java.lang.Comparable<T>>public T aggregateStream(java.util.stream.Stream<T> stream)
IMultisetAggregationOperatoraggregateStream in interface IMultisetAggregationOperator<T extends java.lang.Comparable<T>,java.util.SortedMap<T extends java.lang.Comparable<T>,java.lang.Integer>,T extends java.lang.Comparable<T>>public java.util.SortedMap<T,java.lang.Integer> clone(java.util.SortedMap<T,java.lang.Integer> original)
IMultisetAggregationOperator