| 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. 
 | 
<S> StreamStage<T> | 
StreamStage.filterStateful(SupplierEx<? extends S> createFn,
              BiPredicateEx<? super S,? super T> filterFn)  | 
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> 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> BatchStage<T> | 
BatchStageWithKey.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 © 2022 Hazelcast, Inc.. All rights reserved.