| 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 © 2023 Hazelcast, Inc.. All rights reserved.