## 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 and exception-declaring 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.

- - ### 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<? super com.hazelcast.cache.journal.EventJournalCacheEvent<K, V>>, com.hazelcast.jet.function.DistributedFunction<? super com.hazelcast.cache.journal.EventJournalCacheEvent<K, V>, ? extends T>, com.hazelcast.jet.pipeline.JournalInitialPosition)` and `Sources.remoteCacheJournal(java.lang.String, com.hazelcast.client.config.ClientConfig, com.hazelcast.jet.function.DistributedPredicate<? super com.hazelcast.cache.journal.EventJournalCacheEvent<K, V>>, com.hazelcast.jet.function.DistributedFunction<? super com.hazelcast.cache.journal.EventJournalCacheEvent<K, V>, ? extends 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<? super com.hazelcast.map.journal.EventJournalMapEvent<K, V>>, com.hazelcast.jet.function.DistributedFunction<? super com.hazelcast.map.journal.EventJournalMapEvent<K, V>, ? extends T>, com.hazelcast.jet.pipeline.JournalInitialPosition)` and `Sources.remoteMapJournal(java.lang.String, com.hazelcast.client.config.ClientConfig, com.hazelcast.jet.function.DistributedPredicate<? super com.hazelcast.map.journal.EventJournalMapEvent<K, V>>, com.hazelcast.jet.function.DistributedFunction<? super com.hazelcast.map.journal.EventJournalMapEvent<K, V>, ? extends 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<? super EventJournalCacheEvent<K,V>> predicateFn, DistributedFunction<? super EventJournalCacheEvent<K,V>,? extends T> projectionFn, JournalInitialPosition initialPos, WatermarkGenerationParams<? super T> wmGenParams)` Returns a supplier of processors for `Sources.cacheJournal(String, DistributedPredicate, DistributedFunction, JournalInitialPosition)`.
    `static <T,K,V> ProcessorMetaSupplier` | SourceProcessors.`streamMapP(String mapName, DistributedPredicate<? super EventJournalMapEvent<K,V>> predicateFn, DistributedFunction<? super EventJournalMapEvent<K,V>,? extends 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<? super EventJournalCacheEvent<K,V>> predicateFn, DistributedFunction<? super EventJournalCacheEvent<K,V>,? extends T> projectionFn, JournalInitialPosition initialPos, WatermarkGenerationParams<? super 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<? super EventJournalMapEvent<K,V>> predicateFn, DistributedFunction<? super EventJournalMapEvent<K,V>,? extends T> projectionFn, JournalInitialPosition initialPos, WatermarkGenerationParams<? super 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>` | DistributedPredicate.`alwaysFalse()` Returns a predicate that always evaluates to `false`.
    `static <T> DistributedPredicate<T>` | DistributedPredicate.`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<? super EventJournalCacheEvent<K,V>> predicateFn, DistributedFunction<? super EventJournalCacheEvent<K,V>,? extends T> projectionFn, JournalInitialPosition initialPos)` Returns a source that will stream the `EventJournalCacheEvent` events of a Hazelcast `ICache` with the specified name.
    `StreamStage<T>` | StreamStage.`filter(DistributedPredicate<T> filterFn)`
    `GeneralStage<T>` | GeneralStage.`filter(DistributedPredicate<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(DistributedPredicate<T> filterFn)`
    `static <T,K,V> StreamSource<T>` | Sources.`mapJournal(IMap<? extends K,? extends V> map, DistributedPredicate<? super EventJournalMapEvent<K,V>> predicateFn, DistributedFunction<? super EventJournalMapEvent<K,V>,? extends T> projectionFn, JournalInitialPosition initialPos)` Returns a source that will stream `EventJournalMapEvent`s of the given Hazelcast `IMap`.
    `static <T,K,V> StreamSource<T>` | Sources.`mapJournal(String mapName, DistributedPredicate<? super EventJournalMapEvent<K,V>> predicateFn, DistributedFunction<? super EventJournalMapEvent<K,V>,? extends T> projectionFn, JournalInitialPosition initialPos)` Returns a source that will stream `EventJournalMapEvent`s 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<? super EventJournalCacheEvent<K,V>> predicateFn, DistributedFunction<? super EventJournalCacheEvent<K,V>,? extends 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<? super EventJournalMapEvent<K,V>> predicateFn, DistributedFunction<? super EventJournalMapEvent<K,V>,? extends 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.

Copyright © 2018. All rights reserved.