Uses of Interface
com.hazelcast.function.BiPredicateEx
Package
Description
Serializable and exception-declaring variants of functional interfaces from
java.util.function
.Contains static utility classes with factories of Jet processors.
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
-
Uses of BiPredicateEx in com.hazelcast.function
Modifier and TypeMethodDescriptiondefault BiPredicateEx<T,
U> BiPredicateEx.and
(BiPredicateEx<? super T, ? super U> other) Serializable
variant ofjava.util.function.BiPredicate#and(BiPredicate)
.default BiPredicateEx<T,
U> BiPredicateEx.negate()
Serializable
variant ofjava.util.function.BiPredicate#negate()
.default BiPredicateEx<T,
U> BiPredicateEx.or
(BiPredicateEx<? super T, ? super U> other) Serializable
variant ofjava.util.function.BiPredicate#or(BiPredicate)
.Modifier and TypeMethodDescriptiondefault BiPredicateEx<T,
U> BiPredicateEx.and
(BiPredicateEx<? super T, ? super U> other) Serializable
variant ofjava.util.function.BiPredicate#and(BiPredicate)
.default BiPredicateEx<T,
U> BiPredicateEx.or
(BiPredicateEx<? super T, ? super U> other) Serializable
variant ofjava.util.function.BiPredicate#or(BiPredicate)
. -
Uses of BiPredicateEx in com.hazelcast.jet.core.processor
Modifier and TypeMethodDescriptionstatic <C,
S, T> ProcessorSupplier Processors.filterUsingServiceP
(ServiceFactory<C, S> serviceFactory, BiPredicateEx<? super S, ? super T> filterFn) Returns a supplier of processors for a vertex that emits the same items it receives, but only those that pass the given predicate. -
Uses of BiPredicateEx in com.hazelcast.jet.pipeline
Modifier and TypeMethodDescription<S> BatchStage<T>
BatchStage.filterStateful
(SupplierEx<? extends S> createFn, BiPredicateEx<? super S, ? super T> filterFn) <S> BatchStage<T>
BatchStageWithKey.filterStateful
(SupplierEx<? extends S> createFn, BiPredicateEx<? super S, ? super T> filterFn) <S> GeneralStage<T>
GeneralStage.filterStateful
(SupplierEx<? extends S> createFn, BiPredicateEx<? super S, ? super T> filterFn) Attaches a stage that performs a stateful filtering operation.<S> GeneralStage<T>
GeneralStageWithKey.filterStateful
(SupplierEx<? extends S> createFn, BiPredicateEx<? super S, ? super T> filterFn) Attaches a stage that performs a stateful filtering operation.<S> StreamStage<T>
StreamStage.filterStateful
(SupplierEx<? extends S> createFn, BiPredicateEx<? super S, ? super T> filterFn) <S> StreamStage<T>
StreamStageWithKey.filterStateful
(long ttl, SupplierEx<? extends S> createFn, BiPredicateEx<? super S, ? super T> filterFn) Attaches a stage that performs a stateful filtering operation.default <S> StreamStage<T>
StreamStageWithKey.filterStateful
(SupplierEx<? extends S> createFn, BiPredicateEx<? super S, ? super T> filterFn) <S> BatchStage<T>
BatchStage.filterUsingService
(ServiceFactory<?, S> serviceFactory, BiPredicateEx<? super S, ? super T> filterFn) <S> GeneralStage<T>
GeneralStage.filterUsingService
(ServiceFactory<?, S> serviceFactory, BiPredicateEx<? super S, ? super T> filterFn) Attaches a filtering stage which applies the provided predicate function to each input item to decide whether to pass the item to the output or to discard it.<S> StreamStage<T>
StreamStage.filterUsingService
(ServiceFactory<?, S> serviceFactory, BiPredicateEx<? super S, ? super T> filterFn)