Uses of Interface
com.hazelcast.function.BiPredicateEx
Packages that use 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
Methods in com.hazelcast.function that return BiPredicateExModifier and TypeMethodDescriptiondefault BiPredicateEx<T,U> BiPredicateEx.and(BiPredicateEx<? super T, ? super U> other) Serializablevariant ofjava.util.function.BiPredicate#and(BiPredicate).default BiPredicateEx<T,U> BiPredicateEx.negate()Serializablevariant ofjava.util.function.BiPredicate#negate().default BiPredicateEx<T,U> BiPredicateEx.or(BiPredicateEx<? super T, ? super U> other) Serializablevariant ofjava.util.function.BiPredicate#or(BiPredicate).Methods in com.hazelcast.function with parameters of type BiPredicateExModifier and TypeMethodDescriptiondefault BiPredicateEx<T,U> BiPredicateEx.and(BiPredicateEx<? super T, ? super U> other) Serializablevariant ofjava.util.function.BiPredicate#and(BiPredicate).default BiPredicateEx<T,U> BiPredicateEx.or(BiPredicateEx<? super T, ? super U> other) Serializablevariant 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 BiPredicateExModifier 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
Methods in com.hazelcast.jet.pipeline with parameters of type BiPredicateExModifier 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)