Uses of Interface
com.hazelcast.function.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 several its 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 Description static <T> PredicateEx<T>
PredicateEx. alwaysFalse()
Returns a predicate that always evaluates tofalse
.static <T> PredicateEx<T>
PredicateEx. alwaysTrue()
Returns a predicate that always evaluates totrue
.default PredicateEx<T>
PredicateEx. and(PredicateEx<? super T> other)
Serializable
variant ofjava.util.function.Predicate#and(Predicate)
.static <T> PredicateEx<T>
PredicateEx. isEqual(Object other)
Serializable
variant ofdefault PredicateEx<T>
PredicateEx. negate()
Serializable
variant ofPredicate.negate()
.default PredicateEx<T>
PredicateEx. or(PredicateEx<? super T> other)
Serializable
variant ofjava.util.function.Predicate#or(Predicate)
.Methods in com.hazelcast.function with parameters of type PredicateEx Modifier and Type Method Description default PredicateEx<T>
PredicateEx. and(PredicateEx<? super T> other)
Serializable
variant ofjava.util.function.Predicate#and(Predicate)
.default PredicateEx<T>
PredicateEx. or(PredicateEx<? super T> other)
Serializable
variant ofjava.util.function.Predicate#or(Predicate)
. -
Uses of PredicateEx in com.hazelcast.jet
-
Uses of PredicateEx in com.hazelcast.jet.aggregate
Methods in com.hazelcast.jet.aggregate with parameters of type PredicateEx Modifier and Type Method 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 thefilterFn
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 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> SupplierEx<Processor>
DiagnosticProcessors. peekInputP(FunctionEx<T,? extends CharSequence> toStringFn, PredicateEx<T> shouldLogFn, SupplierEx<Processor> wrapped)
Same aspeekInput(toStringFn, shouldLogFn, metaSupplier)
, but accepts aSupplierEx
of processors instead of a meta-supplier.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 aspeekInput(toStringFn, shouldLogFn, metaSupplier)
, but accepts aProcessorSupplier
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 aspeekOutput(toStringFn, shouldLogFn, metaSupplier)
, but accepts aSupplierEx
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 aspeekOutput(toStringFn, shouldLogFn, metaSupplier)
, but accepts aProcessorSupplier
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 aspeekSnapshot(toStringFn, shouldLogFn, metaSupplier)
, but accepts aSupplierEx
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 aspeekSnapshot(toStringFn, shouldLogFn, metaSupplier)
, but accepts aProcessorSupplier
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 forSources.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 forSources.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 forSources.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 forSources.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 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 theEventJournalCacheEvent
events of a HazelcastICache
with the specified name.BatchStage<T>
BatchStage. 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.StreamStage<T>
StreamStage. 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 streamEventJournalMapEvent
s of the given HazelcastIMap
.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 streamEventJournalMapEvent
s of the HazelcastIMap
with the specified name.BatchStage<T>
BatchStage. 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.StreamStage<T>
StreamStage. 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 theEventJournalCacheEvent
events of the HazelcastICache
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 theEventJournalMapEvent
events of the HazelcastIMap
with the specified name from a remote cluster.