## Uses of Interface
com.hazelcast.map.journal.EventJournalMapEvent

- Packages that use EventJournalMapEvent
  Package | Description
  --- | ---
  com.hazelcast.client.proxy | This package contains client side proxy implementations of the different Hazelcast data structures and operation types
  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 EventJournalMapEvent in com.hazelcast.client.proxy

    Method parameters in com.hazelcast.client.proxy with type arguments of type EventJournalMapEvent
    Modifier and Type | Method and Description
    --- | ---
    `<T> ICompletableFuture<ReadResultSet<T>>` | ClientMapProxy.`readFromEventJournal(long startSequence, int minSize, int maxSize, int partitionId, Predicate<? super EventJournalMapEvent<K,V>> predicate, Projection<? super EventJournalMapEvent<K,V>,? extends T> projection)`
    `<T> ICompletableFuture<ReadResultSet<T>>` | ClientMapProxy.`readFromEventJournal(long startSequence, int minSize, int maxSize, int partitionId, Predicate<? super EventJournalMapEvent<K,V>> predicate, Projection<? super EventJournalMapEvent<K,V>,? extends T> projection)`

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

    Methods in com.hazelcast.jet that return types with arguments of type EventJournalMapEvent
    Modifier and Type | Method and Description
    --- | ---
    `static <K,V> DistributedFunction<EventJournalMapEvent<K,V>,V>` | Util.`mapEventNewValue()` Returns a projection that extracts the new value from a `EventJournalMapEvent`.
    `static <K,V> DistributedFunction<EventJournalMapEvent<K,V>,Map.Entry<K,V>>` | Util.`mapEventToEntry()` Returns a projection that converts the `EventJournalMapEvent` to a `Map.Entry` using the event's new value as a value.
    `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 EventJournalMapEvent in com.hazelcast.jet.core.processor

    Method parameters in com.hazelcast.jet.core.processor with type arguments of type EventJournalMapEvent
    Modifier and Type | Method and Description
    --- | ---
    `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.`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.`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)`.
    `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 EventJournalMapEvent in com.hazelcast.jet.pipeline

    Method parameters in com.hazelcast.jet.pipeline with type arguments of type EventJournalMapEvent
    Modifier and Type | Method and Description
    --- | ---
    `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(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.
    `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.
    `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.
    `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.