Uses of Interface
com.hazelcast.jet.function.DistributedPredicate

Packages that use DistributedPredicate

Package	Description
com.hazelcast.jet	Hazelcast Jet is a distributed computation engine running on top of Hazelcast IMDG technology.
com.hazelcast.jet.core.processor	Contains static utility classes with factories of Jet processors.
com.hazelcast.jet.function	Serializable variants of functional interfaces from java.util.function.
com.hazelcast.jet.pipeline	The Pipeline API is Jet's high-level API to build and execute distributed computation jobs.
com.hazelcast.jet.stream	java.util.stream implementation using Hazelcast Jet

Uses of DistributedPredicate in com.hazelcast.jet

Methods in com.hazelcast.jet that return DistributedPredicate

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

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

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

Modifier and Type	Method and Description
static <T> DistributedSupplier<Processor>	Processors.filterP(DistributedPredicate<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> DistributedSupplier<Processor>	DiagnosticProcessors.peekInputP(DistributedFunction<T,? extends CharSequence> toStringFn, DistributedPredicate<T> shouldLogFn, DistributedSupplier<Processor> wrapped) Same as peekInput(toStringFn, shouldLogFn, metaSupplier), but accepts a DistributedSupplier of processors instead of a meta-supplier.
static <T> ProcessorMetaSupplier	DiagnosticProcessors.peekInputP(DistributedFunction<T,? extends CharSequence> toStringFn, DistributedPredicate<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(DistributedFunction<T,? extends CharSequence> toStringFn, DistributedPredicate<T> shouldLogFn, ProcessorSupplier wrapped) Same as peekInput(toStringFn, shouldLogFn, metaSupplier), but accepts a ProcessorSupplier instead of a meta-supplier.
static <T> DistributedSupplier<Processor>	DiagnosticProcessors.peekOutputP(DistributedFunction<? super T,? extends CharSequence> toStringFn, DistributedPredicate<? super T> shouldLogFn, DistributedSupplier<Processor> wrapped) Same as peekOutput(toStringFn, shouldLogFn, metaSupplier), but accepts a DistributedSupplier of processors instead of a meta-supplier.
static <T> ProcessorMetaSupplier	DiagnosticProcessors.peekOutputP(DistributedFunction<? super T,? extends CharSequence> toStringFn, DistributedPredicate<? 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(DistributedFunction<? super T,? extends CharSequence> toStringFn, DistributedPredicate<? super T> shouldLogFn, ProcessorSupplier wrapped) Same as peekOutput(toStringFn, shouldLogFn, metaSupplier), but accepts a ProcessorSupplier instead of a meta-supplier.
static <K,V> DistributedSupplier<Processor>	DiagnosticProcessors.peekSnapshotP(DistributedFunction<? super Map.Entry<K,V>,? extends CharSequence> toStringFn, DistributedPredicate<? super Map.Entry<K,V>> shouldLogFn, DistributedSupplier<Processor> wrapped) Same as peekSnapshot(toStringFn, shouldLogFn, metaSupplier), but accepts a DistributedSupplier of processors instead of a meta-supplier.
static <K,V> ProcessorMetaSupplier	DiagnosticProcessors.peekSnapshotP(DistributedFunction<? super Map.Entry<K,V>,? extends CharSequence> toStringFn, DistributedPredicate<? 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(DistributedFunction<? super Map.Entry<K,V>,? extends CharSequence> toStringFn, DistributedPredicate<? super Map.Entry<K,V>> shouldLogFn, ProcessorSupplier wrapped) Same as peekSnapshot(toStringFn, shouldLogFn, metaSupplier), but accepts a ProcessorSupplier instead of a meta-supplier.
static <T,K,V> ProcessorMetaSupplier	SourceProcessors.streamCacheP(String cacheName, DistributedPredicate<EventJournalCacheEvent<K,V>> predicateFn, DistributedFunction<EventJournalCacheEvent<K,V>,T> projectionFn, JournalInitialPosition initialPos, WatermarkGenerationParams<T> wmGenParams) Returns a supplier of processors for Sources.cacheJournal(String, DistributedPredicate, DistributedFunction, JournalInitialPosition).
static <T,K,V> ProcessorMetaSupplier	SourceProcessors.streamMapP(String mapName, DistributedPredicate<EventJournalMapEvent<K,V>> predicateFn, DistributedFunction<EventJournalMapEvent<K,V>,T> projectionFn, JournalInitialPosition initialPos, WatermarkGenerationParams<? super T> wmGenParams) Returns a supplier of processors for Sources.mapJournal(String, DistributedPredicate, DistributedFunction, JournalInitialPosition).
static <T,K,V> ProcessorMetaSupplier	SourceProcessors.streamRemoteCacheP(String cacheName, ClientConfig clientConfig, DistributedPredicate<EventJournalCacheEvent<K,V>> predicateFn, DistributedFunction<EventJournalCacheEvent<K,V>,T> projectionFn, JournalInitialPosition initialPos, WatermarkGenerationParams<T> wmGenParams) Returns a supplier of processors for Sources.remoteCacheJournal(String, ClientConfig, DistributedPredicate, DistributedFunction, JournalInitialPosition).
static <T,K,V> ProcessorMetaSupplier	SourceProcessors.streamRemoteMapP(String mapName, ClientConfig clientConfig, DistributedPredicate<EventJournalMapEvent<K,V>> predicateFn, DistributedFunction<EventJournalMapEvent<K,V>,T> projectionFn, JournalInitialPosition initialPos, WatermarkGenerationParams<T> wmGenParams) Returns a supplier of processors for Sources.remoteMapJournal(String, ClientConfig, DistributedPredicate, DistributedFunction, JournalInitialPosition).

Uses of DistributedPredicate in com.hazelcast.jet.function

Methods in com.hazelcast.jet.function that return DistributedPredicate

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

Methods in com.hazelcast.jet.function with parameters of type DistributedPredicate

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

Uses of DistributedPredicate in com.hazelcast.jet.pipeline

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

Modifier and Type	Method and Description
static <T,K,V> StreamSource<T>	Sources.cacheJournal(String cacheName, DistributedPredicate<EventJournalCacheEvent<K,V>> predicateFn, DistributedFunction<EventJournalCacheEvent<K,V>,T> projectionFn, JournalInitialPosition initialPos) Returns a source that will stream the EventJournalCacheEvent events of the Hazelcast ICache with the specified name.
StreamStage<T>	StreamStage.filter(DistributedPredicate<T> filterFn)
GeneralStage<T>	GeneralStage.filter(DistributedPredicate<T> filterFn) Attaches to this stage a filtering stage, one 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(DistributedPredicate<T> filterFn)
static <T,K,V> StreamSource<T>	Sources.mapJournal(String mapName, DistributedPredicate<EventJournalMapEvent<K,V>> predicateFn, DistributedFunction<EventJournalMapEvent<K,V>,T> projectionFn, JournalInitialPosition initialPos) Returns a source that will stream EventJournalMapEvents of the Hazelcast IMap with the specified name.
StreamStage<T>	StreamStage.peek(DistributedPredicate<? super T> shouldLogFn, DistributedFunction<? super T,? extends CharSequence> toStringFn)
GeneralStage<T>	GeneralStage.peek(DistributedPredicate<? super T> shouldLogFn, DistributedFunction<? 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(DistributedPredicate<? super T> shouldLogFn, DistributedFunction<? super T,? extends CharSequence> toStringFn)
static <T,K,V> StreamSource<T>	Sources.remoteCacheJournal(String cacheName, ClientConfig clientConfig, DistributedPredicate<EventJournalCacheEvent<K,V>> predicateFn, DistributedFunction<EventJournalCacheEvent<K,V>,T> projectionFn, JournalInitialPosition initialPos) 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, DistributedPredicate<EventJournalMapEvent<K,V>> predicateFn, DistributedFunction<EventJournalMapEvent<K,V>,T> projectionFn, JournalInitialPosition initialPos) Returns a source that will stream the EventJournalMapEvent events of the Hazelcast IMap with the specified name from a remote cluster.

Uses of DistributedPredicate in com.hazelcast.jet.stream

Methods in com.hazelcast.jet.stream with parameters of type DistributedPredicate

Modifier and Type	Method and Description
default boolean	DistributedStream.allMatch(DistributedPredicate<? super T> predicate) Serializable variant of java.util.stream.Stream#allMatch(Predicate).
default boolean	DistributedStream.anyMatch(DistributedPredicate<? super T> predicate) Serializable variant of java.util.stream.Stream#anyMatch(Predicate).
default DistributedStream<T>	DistributedStream.filter(DistributedPredicate<? super T> predicate) Serializable variant of java.util.stream.Stream#filter(Predicate).
default boolean	DistributedStream.noneMatch(DistributedPredicate<? super T> predicate) Serializable variant of java.util.stream.Stream#noneMatch(Predicate).
static <T> Collector<T,?,Map<Boolean,List<T>>>	DistributedCollectors.partitioningBy(DistributedPredicate<? super T> predicate) Serializable variant of java.util.stream.Collectors#partitioningBy(Predicate)
static <T,D,A> Collector<T,?,Map<Boolean,D>>	DistributedCollectors.partitioningBy(DistributedPredicate<? super T> predicate, DistributedCollector<? super T,A,D> downstream) Serializable variant of java.util.stream.Collectors#partitioningBy(Predicate, Collector)