Package | Description |
---|---|
com.hazelcast.function |
Serializable and exception-declaring variants of functional interfaces from
java.util.function . |
com.hazelcast.jet.aggregate |
Contains
AggregateOperation and its several variants, as well
as a builder object for the aggregate operations. |
com.hazelcast.jet.core |
Jet's Core API.
|
com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
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) . |
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 |
---|---|
ComparatorEx<?> |
Edge.getOrderComparator()
Returns the comparator defined on this edge using
Edge.ordered(ComparatorEx) . |
Modifier and Type | Method and Description |
---|---|
Edge |
Edge.ordered(ComparatorEx<?> comparator)
Specifies that the data traveling on this edge is ordered according to
the provided comparator.
|
Modifier and Type | Method and Description |
---|---|
BatchStage<T> |
BatchStage.sort(ComparatorEx<? super T> comparator)
Attaches a stage that sorts the input items according to the supplied
comparator.
|
Copyright © 2021 Hazelcast, Inc.. All rights reserved.