Uses of Interface
com.hazelcast.jet.function.TriPredicate

Packages that use TriPredicate

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

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

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

Modifier and Type	Method	Description
static <T, K, S, R> SupplierEx<Processor>	Processors.flatMapStatefulP(long ttl, FunctionEx<? super T,? extends K> keyFn, ToLongFunctionEx<? super T> timestampFn, Supplier<? extends S> createFn, TriFunction<? super S,? super K,? super T,? extends Traverser<R>> statefulFlatMapFn, TriPredicate<? super S,? super K,? super T> deleteStatePredicate, TriFunction<? super S,? super K,? super Long,? extends Traverser<R>> onEvictFn)	Returns a supplier of processors for a vertex that performs a stateful flat-mapping of its input.
static <T, K, S, R> SupplierEx<Processor>	Processors.mapStatefulP(long ttl, FunctionEx<? super T,? extends K> keyFn, ToLongFunctionEx<? super T> timestampFn, Supplier<? extends S> createFn, TriFunction<? super S,? super K,? super T,? extends R> statefulMapFn, TriPredicate<? super S,? super K,? super T> deleteStatePredicate, TriFunction<? super S,? super K,? super Long,? extends R> onEvictFn)	Returns a supplier of processors for a vertex that performs a stateful mapping of its input.

Uses of TriPredicate in com.hazelcast.jet.function

Methods in com.hazelcast.jet.function that return TriPredicate

Modifier and Type	Method	Description
default TriPredicate<T,U,V>	TriPredicate.and(TriPredicate<? super T,? super U,? super V> other)	Returns a composite predicate which evaluates the equivalent of this.test(t, u, v) && other.test(t, u, v).
default TriPredicate<T,U,V>	TriPredicate.negate()	Returns a composite predicate which evaluates the equivalent of !this.test(t, u, v).
default TriPredicate<T,U,V>	TriPredicate.or(TriPredicate<? super T,? super U,? super V> other)	Returns a composite predicate which evaluates the equivalent of this.test(t, u, v) || other.test(t, u, v).

Methods in com.hazelcast.jet.function with parameters of type TriPredicate

Modifier and Type	Method	Description
default TriPredicate<T,U,V>	TriPredicate.and(TriPredicate<? super T,? super U,? super V> other)	Returns a composite predicate which evaluates the equivalent of this.test(t, u, v) && other.test(t, u, v).
default TriPredicate<T,U,V>	TriPredicate.or(TriPredicate<? super T,? super U,? super V> other)	Returns a composite predicate which evaluates the equivalent of this.test(t, u, v) || other.test(t, u, v).

Uses of TriPredicate in com.hazelcast.jet.pipeline

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

Modifier and Type	Method	Description
<S> BatchStage<T>	BatchStageWithKey.filterStateful(SupplierEx<? extends S> createFn, BiPredicateEx<? super S,? super T> filterFn, TriPredicate<? super S,? super K,? super T> deleteStatePredicate)	The same as BatchStageWithKey.filterStateful(SupplierEx, BiPredicateEx), with an additional parameter deleteStatePredicate that allows the state to be deleted.
<S> StreamStage<T>	StreamStageWithKey.filterStateful(long ttl, SupplierEx<? extends S> createFn, BiPredicateEx<? super S,? super T> filterFn, TriPredicate<? super S,? super K,? super T> deleteStatePredicate)	The same as StreamStageWithKey.filterStateful(long, SupplierEx, BiPredicateEx), with an additional parameter deleteStatePredicate that allows the state to be deleted before the TTL-based eviction occurs.
<S> BatchStage<T>	BatchStageWithKey.filterUsingService(ServiceFactory<?,S> serviceFactory, TriPredicate<? super S,? super K,? super T> filterFn)
<S> GeneralStage<T>	GeneralStageWithKey.filterUsingService(ServiceFactory<?,S> serviceFactory, TriPredicate<? super S,? super K,? super T> filterFn)	Deprecated. Jet now has first-class support for data rebalancing, see GeneralStage.rebalance() and GeneralStage.rebalance(FunctionEx).
<S> StreamStage<T>	StreamStageWithKey.filterUsingService(ServiceFactory<?,S> serviceFactory, TriPredicate<? super S,? super K,? super T> filterFn)
<S, R> BatchStage<R>	BatchStageWithKey.flatMapStateful(SupplierEx<? extends S> createFn, TriFunction<? super S,? super K,? super T,? extends Traverser<R>> flatMapFn, TriPredicate<? super S,? super K,? super T> deleteStatePredicate)	The same as BatchStageWithKey.flatMapStateful(SupplierEx, TriFunction)}, with an additional parameter deleteStatePredicate that allows the state to be deleted.
<S, R> StreamStage<R>	StreamStageWithKey.flatMapStateful(long ttl, SupplierEx<? extends S> createFn, TriFunction<? super S,? super K,? super T,? extends Traverser<R>> flatMapFn, TriPredicate<? super S,? super K,? super T> deleteStatePredicate, TriFunction<? super S,? super K,? super Long,? extends Traverser<R>> onEvictFn)	The same as StreamStageWithKey.flatMapStateful(long, SupplierEx, TriFunction, TriFunction), with an additional parameter deleteStatePredicate that allows the state to be deleted before the TTL-based eviction occurs.
<S, R> BatchStage<R>	BatchStageWithKey.mapStateful(SupplierEx<? extends S> createFn, TriFunction<? super S,? super K,? super T,? extends R> mapFn, TriPredicate<? super S,? super K,? super T> deleteStatePredicate)	The same as BatchStageWithKey.mapStateful(SupplierEx, TriFunction), with an additional parameter deleteStatePredicate that allows the state to be deleted.
<S, R> StreamStage<R>	StreamStageWithKey.mapStateful(long ttl, SupplierEx<? extends S> createFn, TriFunction<? super S,? super K,? super T,? extends R> mapFn, TriPredicate<? super S,? super K,? super T> deleteStatePredicate, TriFunction<? super S,? super K,? super Long,? extends R> onEvictFn)	The same as StreamStageWithKey.mapStateful(long, SupplierEx, TriFunction, TriFunction), with an additional parameter deleteStatePredicate that allows the state to be deleted before the TTL-based eviction occurs.