Uses of Interface
com.hazelcast.function.BiPredicateEx

Packages that use BiPredicateEx

Package	Description
com.hazelcast.function	Serializable and exception-declaring variants of functional interfaces from java.util.function.
com.hazelcast.jet.core.processor	Contains static utility classes with factories of Jet processors.
com.hazelcast.jet.pipeline	The Pipeline API is Jet's high-level API to build and execute distributed computation jobs.

Uses of BiPredicateEx in com.hazelcast.function

Methods in com.hazelcast.function that return BiPredicateEx

Modifier and Type	Method and Description
default BiPredicateEx<T,U>	BiPredicateEx.and(BiPredicateEx<? super T,? super U> other) Serializable variant of java.util.function.BiPredicate#and(BiPredicate).
default BiPredicateEx<T,U>	BiPredicateEx.negate() Serializable variant of java.util.function.BiPredicate#negate().
default BiPredicateEx<T,U>	BiPredicateEx.or(BiPredicateEx<? super T,? super U> other) Serializable variant of java.util.function.BiPredicate#or(BiPredicate).

Methods in com.hazelcast.function with parameters of type BiPredicateEx

Modifier and Type	Method and Description
default BiPredicateEx<T,U>	BiPredicateEx.and(BiPredicateEx<? super T,? super U> other) Serializable variant of java.util.function.BiPredicate#and(BiPredicate).
default BiPredicateEx<T,U>	BiPredicateEx.or(BiPredicateEx<? super T,? super U> other) Serializable variant of java.util.function.BiPredicate#or(BiPredicate).

Uses of BiPredicateEx in com.hazelcast.jet.core.processor

Methods in com.hazelcast.jet.core.processor with parameters of type BiPredicateEx

Modifier and Type	Method and Description
static <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

Methods in com.hazelcast.jet.pipeline with parameters of type BiPredicateEx

Modifier and Type	Method and Description
<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.
<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> BatchStage<T>	BatchStage.filterStateful(SupplierEx<? extends S> createFn, BiPredicateEx<? super S,? super T> filterFn)
default <S> StreamStage<T>	StreamStageWithKey.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> StreamStage<T>	StreamStage.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> BatchStage<T>	BatchStage.filterUsingService(ServiceFactory<?,S> serviceFactory, BiPredicateEx<? super S,? super T> filterFn)
<S> StreamStage<T>	StreamStage.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.