Package | Description |
---|---|
com.hazelcast.jet.aggregate |
Contains
AggregateOperation and several its variants, as well
as a builder object for the aggregate operations. |
com.hazelcast.jet.function |
Serializable and exception-declaring variants of functional interfaces from
java.util.function . |
Modifier and Type | Method and Description |
---|---|
static <T> AggregateOperation1<T,PriorityQueue<T>,List<T>> |
AggregateOperations.bottomN(int n,
ComparatorEx<? super T> comparator)
Returns an aggregate operation that finds the bottom
n items
according to the given comparator . |
static <T> AggregateOperation1<T,MutableReference<T>,T> |
AggregateOperations.maxBy(ComparatorEx<? super T> comparator)
Returns an aggregate operation that computes the greatest item according
to the given
comparator . |
static <T> AggregateOperation1<T,MutableReference<T>,T> |
AggregateOperations.minBy(ComparatorEx<? super T> comparator)
Returns an aggregate operation that computes the least item according to
the given
comparator . |
static <T> AggregateOperation1<T,ArrayList<T>,List<T>> |
AggregateOperations.sorting(ComparatorEx<? super T> comparator)
Returns an aggregate operation that accumulates all input items into an
ArrayList and sorts it with the given comparator. |
static <T> AggregateOperation1<T,PriorityQueue<T>,List<T>> |
AggregateOperations.topN(int n,
ComparatorEx<? super T> comparator)
Returns an aggregate operation that finds the top
n items
according to the given comparator . |
Modifier and Type | Method and Description |
---|---|
static <T,U> ComparatorEx<T> |
ComparatorEx.comparing(FunctionEx<? super T,? extends U> toKeyFn,
ComparatorEx<? super U> keyComparator)
Serializable variant of java.util.Comparator#comparing(Function, Comparator) . |
static <T> ComparatorEx<T> |
ComparatorEx.nullsFirst(ComparatorEx<? super T> comparator)
Serializable variant of java.util.Comparator#nullsFirst(Comparator) . |
static <T> ComparatorEx<T> |
ComparatorEx.nullsLast(ComparatorEx<? super T> comparator)
Serializable variant of java.util.Comparator#nullsLast(Comparator) . |
default ComparatorEx<T> |
ComparatorEx.thenComparing(ComparatorEx<? super T> other)
Serializable variant of java.util.Comparator#thenComparing(Comparator) . |
default <U> ComparatorEx<T> |
ComparatorEx.thenComparing(FunctionEx<? super T,? extends U> toKeyFn,
ComparatorEx<? super U> keyComparator)
Serializable variant of java.util.Comparator#thenComparing(Function, Comparator) . |
Copyright © 2019 Hazelcast, Inc.. All rights reserved.