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 variants of functional interfaces from
java.util.function . |
com.hazelcast.jet.stream |
java.util.stream implementation using Hazelcast Jet
|
Modifier and Type | Method and Description |
---|---|
static <T> AggregateOperation1<T,MutableReference<T>,T> |
AggregateOperations.maxBy(DistributedComparator<? super T> comparator)
Returns an operation that returns the maximum item, according the given
comparator . |
static <T> AggregateOperation1<T,MutableReference<T>,T> |
AggregateOperations.minBy(DistributedComparator<? super T> comparator)
Returns an operation that returns the minimum item, according the given
comparator . |
Modifier and Type | Method and Description |
---|---|
static <T,U extends Comparable<? super U>> |
DistributedComparator.comparing(DistributedFunction<? super T,? extends U> keyExtractor) |
static <T,U> DistributedComparator<T> |
DistributedComparator.comparing(DistributedFunction<? super T,? extends U> keyExtractor,
DistributedComparator<? super U> keyComparator) |
static <T,U extends Comparable<? super U>> |
DistributedComparator.comparing(java.util.function.Function<? super T,? extends U> keyExtractor) |
static <T,U> DistributedComparator<T> |
DistributedComparator.comparing(java.util.function.Function<? super T,? extends U> keyExtractor,
Comparator<? super U> keyComparator) |
static <T> DistributedComparator<T> |
DistributedComparator.comparingDouble(DistributedToDoubleFunction<? super T> keyExtractor) |
static <T> DistributedComparator<T> |
DistributedComparator.comparingDouble(java.util.function.ToDoubleFunction<? super T> keyExtractor) |
static <T> DistributedComparator<T> |
DistributedComparator.comparingInt(DistributedToIntFunction<? super T> keyExtractor) |
static <T> DistributedComparator<T> |
DistributedComparator.comparingInt(java.util.function.ToIntFunction<? super T> keyExtractor) |
static <T> DistributedComparator<T> |
DistributedComparator.comparingLong(DistributedToLongFunction<? super T> keyExtractor) |
static <T> DistributedComparator<T> |
DistributedComparator.comparingLong(java.util.function.ToLongFunction<? super T> keyExtractor) |
static <T extends Comparable<? super T>> |
DistributedComparator.naturalOrder()
Returns a comparator that compares
Comparable objects in natural
order. |
static <T> DistributedComparator<T> |
DistributedComparator.nullsFirst(Comparator<? super T> comparator) |
static <T> DistributedComparator<T> |
DistributedComparator.nullsFirst(DistributedComparator<? super T> comparator) |
static <T> DistributedComparator<T> |
DistributedComparator.nullsLast(Comparator<? super T> comparator) |
static <T> DistributedComparator<T> |
DistributedComparator.nullsLast(DistributedComparator<? super T> comparator) |
default DistributedComparator<T> |
DistributedComparator.reversed() |
static <T extends Comparable<? super T>> |
DistributedComparator.reverseOrder()
Returns a comparator that imposes the reverse of the natural
ordering.
|
default DistributedComparator<T> |
DistributedComparator.thenComparing(Comparator<? super T> other) |
default DistributedComparator<T> |
DistributedComparator.thenComparing(DistributedComparator<? super T> other) |
default <U extends Comparable<? super U>> |
DistributedComparator.thenComparing(DistributedFunction<? super T,? extends U> keyExtractor) |
default <U> DistributedComparator<T> |
DistributedComparator.thenComparing(DistributedFunction<? super T,? extends U> keyExtractor,
DistributedComparator<? super U> keyComparator) |
default <U extends Comparable<? super U>> |
DistributedComparator.thenComparing(java.util.function.Function<? super T,? extends U> keyExtractor) |
default <U> DistributedComparator<T> |
DistributedComparator.thenComparing(java.util.function.Function<? super T,? extends U> keyExtractor,
Comparator<? super U> keyComparator) |
default DistributedComparator<T> |
DistributedComparator.thenComparingDouble(DistributedToDoubleFunction<? super T> keyExtractor) |
default DistributedComparator<T> |
DistributedComparator.thenComparingDouble(java.util.function.ToDoubleFunction<? super T> keyExtractor) |
default DistributedComparator<T> |
DistributedComparator.thenComparingInt(DistributedToIntFunction<? super T> keyExtractor) |
default DistributedComparator<T> |
DistributedComparator.thenComparingInt(java.util.function.ToIntFunction<? super T> keyExtractor) |
default DistributedComparator<T> |
DistributedComparator.thenComparingLong(DistributedToLongFunction<? super T> keyExtractor) |
default DistributedComparator<T> |
DistributedComparator.thenComparingLong(java.util.function.ToLongFunction<? super T> keyExtractor) |
Modifier and Type | Method and Description |
---|---|
static <T,U> DistributedComparator<T> |
DistributedComparator.comparing(DistributedFunction<? super T,? extends U> keyExtractor,
DistributedComparator<? super U> keyComparator) |
static <T> DistributedComparator<T> |
DistributedComparator.nullsFirst(DistributedComparator<? super T> comparator) |
static <T> DistributedComparator<T> |
DistributedComparator.nullsLast(DistributedComparator<? super T> comparator) |
default DistributedComparator<T> |
DistributedComparator.thenComparing(DistributedComparator<? super T> other) |
default <U> DistributedComparator<T> |
DistributedComparator.thenComparing(DistributedFunction<? super T,? extends U> keyExtractor,
DistributedComparator<? super U> keyComparator) |
Modifier and Type | Method and Description |
---|---|
default Optional<T> |
DistributedStream.max(DistributedComparator<? super T> comparator)
Returns the maximum element of this stream according to the provided
DistributedComparator . |
static <T> DistributedCollector<T,?,DistributedOptional<T>> |
DistributedCollectors.maxBy(DistributedComparator<? super T> comparator)
Returns a
DistributedCollector that produces the maximal element according
to a given DistributedComparator , described as an Optional<T> . |
default Optional<T> |
DistributedStream.min(DistributedComparator<? super T> comparator)
Returns the minimum element of this stream according to the provided
DistributedComparator . |
static <T> DistributedCollector<T,?,DistributedOptional<T>> |
DistributedCollectors.minBy(DistributedComparator<? super T> comparator)
Returns a
DistributedCollector that produces the minimal element according
to a given DistributedComparator , described as an Optional<T> . |
default DistributedStream<T> |
DistributedStream.sorted(DistributedComparator<? super T> comparator)
Returns a stream consisting of the elements of this stream, sorted
according to the provided
Comparator . |
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.