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 |
---|---|
<C> StreamStage<T> |
StreamStageWithKey.filterUsingContext(ContextFactory<C> contextFactory,
TriPredicate<? super C,? super K,? super T> filterFn) |
<C> GeneralStage<T> |
GeneralStageWithKey.filterUsingContext(ContextFactory<C> contextFactory,
TriPredicate<? super C,? super K,? 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.
|
<C> BatchStage<T> |
BatchStageWithKey.filterUsingContext(ContextFactory<C> contextFactory,
TriPredicate<? super C,? super K,? super T> filterFn) |
Copyright © 2019 Hazelcast, Inc.. All rights reserved.