## Uses of Interface
com.hazelcast.cache.journal.EventJournalCacheEvent

- Packages that use EventJournalCacheEvent
  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.pipeline | The Pipeline API is Jet's high-level API to build and execute distributed computation jobs.

- - ### Uses of EventJournalCacheEvent in com.hazelcast.jet

    Methods in com.hazelcast.jet that return types with arguments of type EventJournalCacheEvent
    Modifier and Type | Method and Description
    --- | ---
    `static <K,V> FunctionEx<EventJournalCacheEvent<K,V>,V>` | Util.`cacheEventNewValue()` Returns a projection that extracts the new value from an `EventJournalCacheEvent`.
    `static <K,V> FunctionEx<EventJournalCacheEvent<K,V>,Map.Entry<K,V>>` | Util.`cacheEventToEntry()` Returns a projection that converts the `EventJournalCacheEvent` to a `Map.Entry` using the event's new value as a value.
    `static <K,V> PredicateEx<EventJournalCacheEvent<K,V>>` | Util.`cachePutEvents()` Returns a predicate for `Sources.cacheJournal(java.lang.String, com.hazelcast.jet.function.PredicateEx<? super com.hazelcast.cache.journal.EventJournalCacheEvent<K, V>>, com.hazelcast.jet.function.FunctionEx<? 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.PredicateEx<? super com.hazelcast.cache.journal.EventJournalCacheEvent<K, V>>, com.hazelcast.jet.function.FunctionEx<? super com.hazelcast.cache.journal.EventJournalCacheEvent<K, V>, ? extends T>, com.hazelcast.jet.pipeline.JournalInitialPosition)` that passes only `CREATED` and `UPDATED` events.

  - ### Uses of EventJournalCacheEvent in com.hazelcast.jet.core.processor

    Method parameters in com.hazelcast.jet.core.processor with type arguments of type EventJournalCacheEvent
    Modifier and Type | Method and Description
    --- | ---
    `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, PredicateEx, FunctionEx, JournalInitialPosition)`.
    `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, PredicateEx, FunctionEx, JournalInitialPosition)`.
    `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, PredicateEx, FunctionEx, JournalInitialPosition)`.
    `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, PredicateEx, FunctionEx, JournalInitialPosition)`.

  - ### Uses of EventJournalCacheEvent in com.hazelcast.jet.pipeline

    Method parameters in com.hazelcast.jet.pipeline with type arguments of type EventJournalCacheEvent
    Modifier and Type | Method and Description
    --- | ---
    `static <T,K,V> StreamSource<T>` | Sources.`cacheJournal(String cacheName, PredicateEx<? super EventJournalCacheEvent<K,V>> predicateFn, FunctionEx<? 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.
    `static <T,K,V> StreamSource<T>` | Sources.`cacheJournal(String cacheName, PredicateEx<? super EventJournalCacheEvent<K,V>> predicateFn, FunctionEx<? 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.
    `static <T,K,V> StreamSource<T>` | Sources.`remoteCacheJournal(String cacheName, ClientConfig clientConfig, PredicateEx<? super EventJournalCacheEvent<K,V>> predicateFn, FunctionEx<? 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.`remoteCacheJournal(String cacheName, ClientConfig clientConfig, PredicateEx<? super EventJournalCacheEvent<K,V>> predicateFn, FunctionEx<? 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.

Copyright © 2019. All rights reserved.