Uses of Class
com.hazelcast.jet.function.DistributedOptional

Packages that use DistributedOptional

Package	Description
com.hazelcast.jet.function	Serializable variants of functional interfaces from java.util.function.
com.hazelcast.jet.stream	java.util.stream implementation using Hazelcast Jet

Uses of DistributedOptional in com.hazelcast.jet.function

Methods in com.hazelcast.jet.function that return DistributedOptional

Modifier and Type	Method and Description
static <T> DistributedOptional<T>	DistributedOptional.empty() Returns an empty Optional instance.
DistributedOptional<T>	DistributedOptional.filter(DistributedPredicate<? super T> predicate) If a value is present, and the value matches the given predicate, return an Optional describing the value, otherwise return an empty Optional.
<U> DistributedOptional<U>	DistributedOptional.flatMap(DistributedFunction<? super T,DistributedOptional<U>> mapper) If a value is present, apply the provided Optional-bearing mapping function to it, return that result, otherwise return an empty Optional.
<U> DistributedOptional<U>	DistributedOptional.map(DistributedFunction<? super T,? extends U> mapper) If a value is present, apply the provided mapping function to it, and if the result is non-null, return an Optional describing the result.
static <T> DistributedOptional<T>	DistributedOptional.of(T value) Returns an Optional with the specified present non-null value.
static <T> DistributedOptional<T>	DistributedOptional.ofNullable(T value) Returns an Optional describing the specified value, if non-null, otherwise returns an empty Optional.

Method parameters in com.hazelcast.jet.function with type arguments of type DistributedOptional

Modifier and Type	Method and Description
<U> DistributedOptional<U>	DistributedOptional.flatMap(DistributedFunction<? super T,DistributedOptional<U>> mapper) If a value is present, apply the provided Optional-bearing mapping function to it, return that result, otherwise return an empty Optional.

Uses of DistributedOptional in com.hazelcast.jet.stream

Methods in com.hazelcast.jet.stream that return types with arguments of type DistributedOptional

Modifier and Type	Method and Description
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>.
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>.
static <T> DistributedCollector<T,?,DistributedOptional<T>>	DistributedCollectors.reducing(DistributedBinaryOperator<T> op) Returns a DistributedCollector which performs a reduction of its input elements under a specified DistributedBinaryOperator.