Uses of Interface
com.hazelcast.function.PredicateEx
Packages that use PredicateEx
Package
Description
Serializable and exception-declaring variants of functional interfaces from
java.util.function.Hazelcast Jet is a distributed computation engine running on top of
Hazelcast IMDG technology.
Contains
AggregateOperation and its several variants, as well
as a builder object for the aggregate operations.Contains static utility classes with factories of Jet processors.
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 PredicateExModifier and TypeMethodDescriptionstatic <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) Serializablevariant ofjava.util.function.Predicate#and(Predicate).static <T> PredicateEx<T>Serializablevariant ofdefault PredicateEx<T>PredicateEx.negate()Serializablevariant ofPredicate.negate().default PredicateEx<T>PredicateEx.or(PredicateEx<? super T> other) Serializablevariant ofjava.util.function.Predicate#or(Predicate).Methods in com.hazelcast.function with parameters of type PredicateExModifier and TypeMethodDescriptiondefault PredicateEx<T>PredicateEx.and(PredicateEx<? super T> other) Serializablevariant ofjava.util.function.Predicate#and(Predicate).default PredicateEx<T>PredicateEx.or(PredicateEx<? super T> other) Serializablevariant ofjava.util.function.Predicate#or(Predicate). -
Uses of PredicateEx in com.hazelcast.jet
Subinterfaces of PredicateEx in com.hazelcast.jetModifier and TypeInterfaceDescriptioninterfaceSelects the members on which a specific job will run.Methods in com.hazelcast.jet that return PredicateExModifier and TypeMethodDescriptionstatic <K,V> PredicateEx<EventJournalCacheEvent<K, V>> Util.cachePutEvents()Returns a predicate forSources.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>>)andSources.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 onlyCREATEDandUPDATEDevents.static <K,V> PredicateEx<EventJournalMapEvent<K, V>> Util.mapPutEvents()Returns a predicate forSources.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>>)andSources.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 onlyADDEDandUPDATEDevents. -
Uses of PredicateEx in com.hazelcast.jet.aggregate
Methods in com.hazelcast.jet.aggregate with parameters of type PredicateExModifier and TypeMethodDescriptionstatic <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 thefilterFnand ignores others. -
Uses of PredicateEx in com.hazelcast.jet.core.processor
Methods in com.hazelcast.jet.core.processor with parameters of type PredicateExModifier and TypeMethodDescriptionstatic <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 aSupplierExof processors instead of a meta-supplier.static <T> ProcessorMetaSupplierDiagnosticProcessors.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> ProcessorSupplierDiagnosticProcessors.peekInputP(FunctionEx<T, ? extends CharSequence> toStringFn, PredicateEx<T> shouldLogFn, ProcessorSupplier wrapped) Same aspeekInput(toStringFn, shouldLogFn, metaSupplier), but accepts aProcessorSupplierinstead 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 aSupplierExof processors instead of a meta-supplier.static <T> ProcessorMetaSupplierDiagnosticProcessors.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> ProcessorSupplierDiagnosticProcessors.peekOutputP(FunctionEx<? super T, ? extends CharSequence> toStringFn, PredicateEx<? super T> shouldLogFn, ProcessorSupplier wrapped) Same aspeekOutput(toStringFn, shouldLogFn, metaSupplier), but accepts aProcessorSupplierinstead 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 aSupplierExof 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 aProcessorSupplierinstead 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 PredicateExModifier and TypeMethodDescriptionstatic <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 theEventJournalCacheEventevents of a HazelcastICachewith the specified name.BatchStage.filter(PredicateEx<T> filterFn) 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.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 streamEventJournalMapEvents 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 streamEventJournalMapEvents of the HazelcastIMapwith the specified name.BatchStage.peek(PredicateEx<? super T> shouldLogFn, FunctionEx<? super T, ? extends CharSequence> toStringFn) 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.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 theEventJournalCacheEventevents of the HazelcastICachewith 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 theEventJournalMapEventevents of the HazelcastIMapwith 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 theSources.remoteMapJournal(String, ClientConfig, JournalInitialPosition, FunctionEx, PredicateEx)method.