Uses of Interface
com.hazelcast.function.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 Description default 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)
.Methods in com.hazelcast.function with parameters of type BiPredicateEx Modifier and Type Method Description default 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
Methods in com.hazelcast.jet.core.processor with parameters of type BiPredicateEx Modifier and Type Method 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 Description <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)