Package | Description |
---|---|
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.
|
Modifier and Type | Method and 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) . |
Modifier and Type | Method and 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) . |
Modifier and Type | Method and Description |
---|---|
<S> StreamStage<T> |
StreamStageWithKey.filterUsingService(ServiceFactory<?,S> serviceFactory,
TriPredicate<? super S,? super K,? super T> filterFn) |
<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) . |
Copyright © 2021 Hazelcast, Inc.. All rights reserved.