## Uses of Class
com.hazelcast.jet.pipeline.JournalInitialPosition

- Packages that use JournalInitialPosition
  Package | Description
  --- | ---
  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 JournalInitialPosition in com.hazelcast.jet.core.processor

    Methods in com.hazelcast.jet.core.processor with parameters of type JournalInitialPosition
    Modifier and Type | Method and Description
    --- | ---
    `static <K,V> ProcessorMetaSupplier` | SourceProcessors.`streamCacheP(String cacheName, JournalInitialPosition initialPos, EventTimePolicy<? super Map.Entry<K,V>> eventTimePolicy)` Returns a supplier of processors for `Sources.cacheJournal(String, 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 <K,V> ProcessorMetaSupplier` | SourceProcessors.`streamMapP(String mapName, JournalInitialPosition initialPos, EventTimePolicy<? super Map.Entry<K,V>> eventTimePolicy)` Returns a supplier of processors for `Sources.mapJournal(String, JournalInitialPosition)` )}.
    `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 for `Sources.mapJournal(String, PredicateEx, FunctionEx, JournalInitialPosition)`.
    `static <K,V> ProcessorMetaSupplier` | SourceProcessors.`streamRemoteCacheP(String cacheName, ClientConfig clientConfig, JournalInitialPosition initialPos, EventTimePolicy<? super Map.Entry<K,V>> eventTimePolicy)` Returns a supplier of processors for `Sources.remoteCacheJournal(String, ClientConfig, 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 <K,V> ProcessorMetaSupplier` | SourceProcessors.`streamRemoteMapP(String mapName, ClientConfig clientConfig, JournalInitialPosition initialPos, EventTimePolicy<? super Map.Entry<K,V>> eventTimePolicy)` Returns a supplier of processors for `Sources.remoteMapJournal(String, ClientConfig, JournalInitialPosition)`.
    `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 for `Sources.remoteMapJournal(String, ClientConfig, PredicateEx, FunctionEx, JournalInitialPosition)`.

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

    Methods in com.hazelcast.jet.pipeline that return JournalInitialPosition
    Modifier and Type | Method and Description
    --- | ---
    `static JournalInitialPosition` | JournalInitialPosition.`valueOf(String name)` Returns the enum constant of this type with the specified name.
    `static JournalInitialPosition[]` | JournalInitialPosition.`values()` Returns an array containing the constants of this enum type, in the order they are declared.

    Methods in com.hazelcast.jet.pipeline with parameters of type JournalInitialPosition
    Modifier and Type | Method and Description
    --- | ---
    `static <K,V> StreamSource<Map.Entry<K,V>>` | Sources.`cacheJournal(String cacheName, JournalInitialPosition initialPos)` Convenience for `Sources.cacheJournal(String, PredicateEx, FunctionEx, JournalInitialPosition)` which will pass only `CREATED` and `UPDATED` events and will project the event's key and new value into a `Map.Entry`.
    `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 <K,V> StreamSource<Map.Entry<K,V>>` | Sources.`mapJournal(IMap<? extends K,? extends V> map, JournalInitialPosition initialPos)` Convenience for `Sources.mapJournal(IMap, PredicateEx, FunctionEx, JournalInitialPosition)` which will pass only `ADDED` and `UPDATED` events and will project the event's key and new value into a `Map.Entry`.
    `static <T,K,V> StreamSource<T>` | Sources.`mapJournal(IMap<? extends K,? extends V> map, PredicateEx<? super EventJournalMapEvent<K,V>> predicateFn, FunctionEx<? super EventJournalMapEvent<K,V>,? extends T> projectionFn, JournalInitialPosition initialPos)` Returns a source that will stream `EventJournalMapEvent`s of the given Hazelcast `IMap`.
    `static <K,V> StreamSource<Map.Entry<K,V>>` | Sources.`mapJournal(String mapName, JournalInitialPosition initialPos)` Convenience for `Sources.mapJournal(String, PredicateEx, FunctionEx, JournalInitialPosition)` which will pass only `ADDED` and `UPDATED` events and will project the event's key and new value into a `Map.Entry`.
    `static <T,K,V> StreamSource<T>` | Sources.`mapJournal(String mapName, PredicateEx<? super EventJournalMapEvent<K,V>> predicateFn, FunctionEx<? 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 <K,V> StreamSource<Map.Entry<K,V>>` | Sources.`remoteCacheJournal(String cacheName, ClientConfig clientConfig, JournalInitialPosition initialPos)` Convenience for `Sources.remoteCacheJournal(String, ClientConfig, PredicateEx, FunctionEx, JournalInitialPosition)` which will pass only `CREATED` and `UPDATED` events and will project the event's key and new value into a `Map.Entry`.
    `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 <K,V> StreamSource<Map.Entry<K,V>>` | Sources.`remoteMapJournal(String mapName, ClientConfig clientConfig, JournalInitialPosition initialPos)` Convenience for `Sources.remoteMapJournal(String, ClientConfig, PredicateEx, FunctionEx, JournalInitialPosition)` which will pass only `ADDED` and `UPDATED` events and will project the event's key and new value into a `Map.Entry`.
    `static <T,K,V> StreamSource<T>` | Sources.`remoteMapJournal(String mapName, ClientConfig clientConfig, PredicateEx<? super EventJournalMapEvent<K,V>> predicateFn, FunctionEx<? 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 © 2019. All rights reserved.