| 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)Serializablevariant ofjava.util.function.BiPredicate#and(BiPredicate). | 
| default BiPredicateEx<T,U> | BiPredicateEx. negate()Serializablevariant ofjava.util.function.BiPredicate#negate(). | 
| default BiPredicateEx<T,U> | BiPredicateEx. or(BiPredicateEx<? super T,? super U> other)Serializablevariant ofjava.util.function.BiPredicate#or(BiPredicate). | 
| Modifier and Type | Method and Description | 
|---|---|
| default BiPredicateEx<T,U> | BiPredicateEx. and(BiPredicateEx<? super T,? super U> other)Serializablevariant ofjava.util.function.BiPredicate#and(BiPredicate). | 
| default BiPredicateEx<T,U> | BiPredicateEx. or(BiPredicateEx<? super T,? super U> other)Serializablevariant ofjava.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> GeneralStage<T> | GeneralStageWithKey. filterStateful(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) | 
| <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) | 
| default <S> StreamStage<T> | StreamStageWithKey. 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.