Uses of Class
com.hazelcast.jet.Distributed.Optional

Packages that use Distributed.Optional

Package	Description
com.hazelcast.jet	Hazelcast Jet is a distributed computation engine.
com.hazelcast.jet.stream	java.util.stream implementation using Hazelcast Jet

Uses of Distributed.Optional in com.hazelcast.jet

Methods in com.hazelcast.jet that return Distributed.Optional

Modifier and Type	Method and Description
static <T> Distributed.Optional<T>	Distributed.Optional.empty() Returns an empty Optional instance.
Distributed.Optional<T>	Distributed.Optional.filter(Distributed.Predicate<? 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> Distributed.Optional<U>	Distributed.Optional.flatMap(Distributed.Function<? super T,Distributed.Optional<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> Distributed.Optional<U>	Distributed.Optional.map(Distributed.Function<? 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> Distributed.Optional<T>	Distributed.Optional.of(T value) Returns an Optional with the specified present non-null value.
static <T> Distributed.Optional<T>	Distributed.Optional.ofNullable(T value) Returns an Optional describing the specified value, if non-null, otherwise returns an empty Optional.

Method parameters in com.hazelcast.jet with type arguments of type Distributed.Optional

Modifier and Type	Method and Description
<U> Distributed.Optional<U>	Distributed.Optional.flatMap(Distributed.Function<? super T,Distributed.Optional<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 Distributed.Optional in com.hazelcast.jet.stream

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

Modifier and Type	Method and Description
static <T> DistributedCollector<T,?,Distributed.Optional<T>>	DistributedCollectors.maxBy(Distributed.Comparator<? super T> comparator) Returns a Distributed.Collector that produces the maximal element according to a given Distributed.Comparator, described as an Optional<T>.
static <T> DistributedCollector<T,?,Distributed.Optional<T>>	DistributedCollectors.minBy(Distributed.Comparator<? super T> comparator) Returns a Distributed.Collector that produces the minimal element according to a given Distributed.Comparator, described as an Optional<T>.
static <T> DistributedCollector<T,?,Distributed.Optional<T>>	DistributedCollectors.reducing(Distributed.BinaryOperator<T> op) Returns a Distributed.Collector which performs a reduction of its input elements under a specified Distributed.BinaryOperator.