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.
|
Modifier and Type | Method and Description |
---|---|
default BiPredicateEx<T,U> |
BiPredicateEx.and(BiPredicateEx<? super T,? super U> other)
Serializable variant of java.util.function.BiPredicate#and(BiPredicate) . |
default BiPredicateEx<T,U> |
BiPredicateEx.negate()
Serializable variant of java.util.function.BiPredicate#negate() . |
default BiPredicateEx<T,U> |
BiPredicateEx.or(BiPredicateEx<? super T,? super U> other)
Serializable variant of java.util.function.BiPredicate#or(BiPredicate) . |
Modifier and Type | Method and Description |
---|---|
default BiPredicateEx<T,U> |
BiPredicateEx.and(BiPredicateEx<? super T,? super U> other)
Serializable variant of java.util.function.BiPredicate#and(BiPredicate) . |
default BiPredicateEx<T,U> |
BiPredicateEx.or(BiPredicateEx<? super T,? super U> other)
Serializable variant of java.util.function.BiPredicate#or(BiPredicate) . |
Modifier and Type | Method and 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.
|
Modifier and Type | Method and Description |
---|---|
<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> GeneralStage<T> |
GeneralStageWithKey.filterStateful(SupplierEx<? extends S> createFn,
BiPredicateEx<? super S,? super T> filterFn)
Attaches a stage that performs a stateful filtering operation.
|
<S> BatchStage<T> |
BatchStageWithKey.filterStateful(SupplierEx<? extends S> createFn,
BiPredicateEx<? super S,? super T> filterFn) |
<S> StreamStage<T> |
StreamStage.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> BatchStage<T> |
BatchStage.filterStateful(SupplierEx<? extends S> createFn,
BiPredicateEx<? super S,? super T> filterFn) |
<S> StreamStage<T> |
StreamStage.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> BatchStage<T> |
BatchStage.filterUsingService(ServiceFactory<?,S> serviceFactory,
BiPredicateEx<? super S,? super T> filterFn) |
Copyright © 2021 Hazelcast, Inc.. All rights reserved.