Uses of Interface
com.hazelcast.function.PredicateEx

Packages that use PredicateEx

Package	Description
com.hazelcast.function	Serializable and exception-declaring variants of functional interfaces from java.util.function.
com.hazelcast.jet	Hazelcast Jet is a distributed computation engine running on top of Hazelcast IMDG technology.
com.hazelcast.jet.aggregate	Contains AggregateOperation and its several variants, as well as a builder object for the aggregate operations.
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.

Uses of PredicateEx in com.hazelcast.function

Methods in com.hazelcast.function that return PredicateEx

Modifier and Type	Method and Description
static <T> PredicateEx<T>	PredicateEx.alwaysFalse() Returns a predicate that always evaluates to false.
static <T> PredicateEx<T>	PredicateEx.alwaysTrue() Returns a predicate that always evaluates to true.
default PredicateEx<T>	PredicateEx.and(PredicateEx<? super T> other) Serializable variant of java.util.function.Predicate#and(Predicate).
static <T> PredicateEx<T>	PredicateEx.isEqual(Object other) Serializable variant of
default PredicateEx<T>	PredicateEx.negate() Serializable variant of Predicate.negate().
default PredicateEx<T>	PredicateEx.or(PredicateEx<? super T> other) Serializable variant of java.util.function.Predicate#or(Predicate).

Methods in com.hazelcast.function with parameters of type PredicateEx

Modifier and Type	Method and Description
default PredicateEx<T>	PredicateEx.and(PredicateEx<? super T> other) Serializable variant of java.util.function.Predicate#and(Predicate).
default PredicateEx<T>	PredicateEx.or(PredicateEx<? super T> other) Serializable variant of java.util.function.Predicate#or(Predicate).

Uses of PredicateEx in com.hazelcast.jet

Methods in com.hazelcast.jet that return PredicateEx

Modifier and Type	Method and Description
static <K,V> PredicateEx<EventJournalCacheEvent<K,V>>	Util.cachePutEvents() Returns a predicate for Sources.cacheJournal(java.lang.String, com.hazelcast.jet.pipeline.JournalInitialPosition, com.hazelcast.function.FunctionEx<? super com.hazelcast.cache.EventJournalCacheEvent<K, V>, ? extends T>, com.hazelcast.function.PredicateEx<? super com.hazelcast.cache.EventJournalCacheEvent<K, V>>) and Sources.remoteCacheJournal(java.lang.String, com.hazelcast.client.config.ClientConfig, com.hazelcast.jet.pipeline.JournalInitialPosition, com.hazelcast.function.FunctionEx<? super com.hazelcast.cache.EventJournalCacheEvent<K, V>, ? extends T>, com.hazelcast.function.PredicateEx<? super com.hazelcast.cache.EventJournalCacheEvent<K, V>>) that passes only CREATED and UPDATED events.
static <K,V> PredicateEx<EventJournalMapEvent<K,V>>	Util.mapPutEvents() Returns a predicate for Sources.mapJournal(java.lang.String, com.hazelcast.jet.pipeline.JournalInitialPosition, com.hazelcast.function.FunctionEx<? super com.hazelcast.map.EventJournalMapEvent<K, V>, ? extends T>, com.hazelcast.function.PredicateEx<? super com.hazelcast.map.EventJournalMapEvent<K, V>>) and Sources.remoteMapJournal(java.lang.String, com.hazelcast.client.config.ClientConfig, com.hazelcast.jet.pipeline.JournalInitialPosition, com.hazelcast.function.FunctionEx<? super com.hazelcast.map.EventJournalMapEvent<K, V>, ? extends T>, com.hazelcast.function.PredicateEx<? super com.hazelcast.map.EventJournalMapEvent<K, V>>) that passes only ADDED and UPDATED events.

Uses of PredicateEx in com.hazelcast.jet.aggregate

Methods in com.hazelcast.jet.aggregate with parameters of type PredicateEx

Modifier and Type	Method and Description
static <T,A,R> AggregateOperation1<T,A,R>	AggregateOperations.filtering(PredicateEx<? super T> filterFn, AggregateOperation1<? super T,A,? extends R> downstream) Adapts an aggregate operation so that it accumulates only the items passing the filterFn and ignores others.

Uses of PredicateEx in com.hazelcast.jet.core.processor

Methods in com.hazelcast.jet.core.processor with parameters of type PredicateEx

Modifier and Type	Method and Description
static <T> SupplierEx<Processor>	Processors.filterP(PredicateEx<? 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.
static <T> ProcessorMetaSupplier	DiagnosticProcessors.peekInputP(FunctionEx<T,? extends CharSequence> toStringFn, PredicateEx<T> shouldLogFn, ProcessorMetaSupplier wrapped) Returns a meta-supplier that wraps the provided one and adds a logging layer to each processor it creates.
static <T> ProcessorSupplier	DiagnosticProcessors.peekInputP(FunctionEx<T,? extends CharSequence> toStringFn, PredicateEx<T> shouldLogFn, ProcessorSupplier wrapped) Same as peekInput(toStringFn, shouldLogFn, metaSupplier), but accepts a ProcessorSupplier instead of a meta-supplier.
static <T> SupplierEx<Processor>	DiagnosticProcessors.peekInputP(FunctionEx<T,? extends CharSequence> toStringFn, PredicateEx<T> shouldLogFn, SupplierEx<Processor> wrapped) Same as peekInput(toStringFn, shouldLogFn, metaSupplier), but accepts a SupplierEx of processors instead of a meta-supplier.
static <T> ProcessorMetaSupplier	DiagnosticProcessors.peekOutputP(FunctionEx<? super T,? extends CharSequence> toStringFn, PredicateEx<? super T> shouldLogFn, ProcessorMetaSupplier wrapped) Returns a meta-supplier that wraps the provided one and adds a logging layer to each processor it creates.
static <T> ProcessorSupplier	DiagnosticProcessors.peekOutputP(FunctionEx<? super T,? extends CharSequence> toStringFn, PredicateEx<? super T> shouldLogFn, ProcessorSupplier wrapped) Same as peekOutput(toStringFn, shouldLogFn, metaSupplier), but accepts a ProcessorSupplier instead of a meta-supplier.
static <T> SupplierEx<Processor>	DiagnosticProcessors.peekOutputP(FunctionEx<? super T,? extends CharSequence> toStringFn, PredicateEx<? super T> shouldLogFn, SupplierEx<Processor> wrapped) Same as peekOutput(toStringFn, shouldLogFn, metaSupplier), but accepts a SupplierEx of processors instead of a meta-supplier.
static <K,V> ProcessorMetaSupplier	DiagnosticProcessors.peekSnapshotP(FunctionEx<? super Map.Entry<K,V>,? extends CharSequence> toStringFn, PredicateEx<? super Map.Entry<K,V>> shouldLogFn, ProcessorMetaSupplier wrapped) Returns a meta-supplier that wraps the provided one and adds a logging layer to each processor it creates.
static <K,V> ProcessorSupplier	DiagnosticProcessors.peekSnapshotP(FunctionEx<? super Map.Entry<K,V>,? extends CharSequence> toStringFn, PredicateEx<? super Map.Entry<K,V>> shouldLogFn, ProcessorSupplier wrapped) Same as peekSnapshot(toStringFn, shouldLogFn, metaSupplier), but accepts a ProcessorSupplier instead of a meta-supplier.
static <K,V> SupplierEx<Processor>	DiagnosticProcessors.peekSnapshotP(FunctionEx<? super Map.Entry<K,V>,? extends CharSequence> toStringFn, PredicateEx<? super Map.Entry<K,V>> shouldLogFn, SupplierEx<Processor> wrapped) Same as peekSnapshot(toStringFn, shouldLogFn, metaSupplier), but accepts a SupplierEx of processors instead of a meta-supplier.
static <T,K,V> ProcessorMetaSupplier	SourceProcessors.streamCacheP(String cacheName, PredicateEx<? super EventJournalCacheEvent<K,V>> predicateFn, FunctionEx<? super EventJournalCacheEvent<K,V>,? extends T> projectionFn, JournalInitialPosition initialPos, EventTimePolicy<? super T> eventTimePolicy) Returns a supplier of processors for Sources.cacheJournal(String, JournalInitialPosition, FunctionEx, PredicateEx).
static <T,K,V> ProcessorMetaSupplier	SourceProcessors.streamMapP(String mapName, PredicateEx<? super EventJournalMapEvent<K,V>> predicateFn, FunctionEx<? super EventJournalMapEvent<K,V>,? extends T> projectionFn, JournalInitialPosition initialPos, EventTimePolicy<? super T> eventTimePolicy) Returns a supplier of processors for Sources.mapJournal(String, JournalInitialPosition, FunctionEx, PredicateEx).
static <T,K,V> ProcessorMetaSupplier	SourceProcessors.streamRemoteCacheP(String cacheName, ClientConfig clientConfig, PredicateEx<? super EventJournalCacheEvent<K,V>> predicateFn, FunctionEx<? super EventJournalCacheEvent<K,V>,? extends T> projectionFn, JournalInitialPosition initialPos, EventTimePolicy<? super T> eventTimePolicy) Returns a supplier of processors for Sources.remoteCacheJournal(String, ClientConfig, JournalInitialPosition, FunctionEx, PredicateEx).
static <T,K,V> ProcessorMetaSupplier	SourceProcessors.streamRemoteMapP(String mapName, ClientConfig clientConfig, PredicateEx<? super EventJournalMapEvent<K,V>> predicateFn, FunctionEx<? super EventJournalMapEvent<K,V>,? extends T> projectionFn, JournalInitialPosition initialPos, EventTimePolicy<? super T> eventTimePolicy) Returns a supplier of processors for Sources.remoteMapJournal(String, ClientConfig, JournalInitialPosition, FunctionEx, PredicateEx).

Uses of PredicateEx in com.hazelcast.jet.pipeline

Methods in com.hazelcast.jet.pipeline with parameters of type PredicateEx

Modifier and Type	Method and Description
static <T,K,V> StreamSource<T>	Sources.cacheJournal(String cacheName, JournalInitialPosition initialPos, FunctionEx<? super EventJournalCacheEvent<K,V>,? extends T> projectionFn, PredicateEx<? super EventJournalCacheEvent<K,V>> predicateFn) Returns a source that will stream the EventJournalCacheEvent events of a Hazelcast ICache with the specified name.
StreamStage<T>	StreamStage.filter(PredicateEx<T> filterFn)
GeneralStage<T>	GeneralStage.filter(PredicateEx<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.
BatchStage<T>	BatchStage.filter(PredicateEx<T> filterFn)
static <T,K,V> StreamSource<T>	Sources.mapJournal(IMap<? extends K,? extends V> map, JournalInitialPosition initialPos, FunctionEx<? super EventJournalMapEvent<K,V>,? extends T> projectionFn, PredicateEx<? super EventJournalMapEvent<K,V>> predicateFn) Returns a source that will stream EventJournalMapEvents of the given Hazelcast IMap.
static <T,K,V> StreamSource<T>	Sources.mapJournal(String mapName, JournalInitialPosition initialPos, FunctionEx<? super EventJournalMapEvent<K,V>,? extends T> projectionFn, PredicateEx<? super EventJournalMapEvent<K,V>> predicateFn) Returns a source that will stream EventJournalMapEvents of the Hazelcast IMap with the specified name.
StreamStage<T>	StreamStage.peek(PredicateEx<? super T> shouldLogFn, FunctionEx<? super T,? extends CharSequence> toStringFn)
GeneralStage<T>	GeneralStage.peek(PredicateEx<? super T> shouldLogFn, FunctionEx<? super T,? extends CharSequence> toStringFn) Attaches a peeking stage which logs this stage's output and passes it through without transformation.
BatchStage<T>	BatchStage.peek(PredicateEx<? super T> shouldLogFn, FunctionEx<? super T,? extends CharSequence> toStringFn)
static <T,K,V> StreamSource<T>	Sources.remoteCacheJournal(String cacheName, ClientConfig clientConfig, JournalInitialPosition initialPos, FunctionEx<? super EventJournalCacheEvent<K,V>,? extends T> projectionFn, PredicateEx<? super EventJournalCacheEvent<K,V>> predicateFn) Returns a source that will stream the EventJournalCacheEvent events of the Hazelcast ICache with the specified name from a remote cluster.
static <T,K,V> StreamSource<T>	Sources.remoteMapJournal(String mapName, ClientConfig clientConfig, JournalInitialPosition initialPos, FunctionEx<? super EventJournalMapEvent<K,V>,? extends T> projectionFn, PredicateEx<? super EventJournalMapEvent<K,V>> predicateFn) Returns a source that will stream the EventJournalMapEvent events of the Hazelcast IMap with the specified name from a remote cluster.
static <T,K,V> StreamSource<T>	Sources.remoteMapJournal(String mapName, DataConnectionRef dataConnectionRef, JournalInitialPosition initialPos, FunctionEx<? super EventJournalMapEvent<K,V>,? extends T> projectionFn, PredicateEx<? super EventJournalMapEvent<K,V>> predicateFn) The same as the Sources.remoteMapJournal(String, ClientConfig, JournalInitialPosition, FunctionEx, PredicateEx) method.