Uses of Class
com.hazelcast.jet.pipeline.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
-
Uses of JournalInitialPosition in com.hazelcast.jet.pipeline
Methods in com.hazelcast.jet.pipeline that return JournalInitialPosition Modifier and Type Method 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 Description static <K, V> StreamSource<Map.Entry<K,V>>
Sources. cacheJournal(String cacheName, JournalInitialPosition initialPos)
Convenience forSources.cacheJournal(String, JournalInitialPosition, FunctionEx, PredicateEx)
which will pass onlyCREATED
andUPDATED
events and will project the event's key and new value into aMap.Entry
.static <T, K, V> StreamSource<T>
Sources. cacheJournal(String cacheName, JournalInitialPosition initialPos, FunctionEx<? super EventJournalCacheEvent<K,V>,? extends T> projectionFn, PredicateEx<? super EventJournalCacheEvent<K,V>> predicateFn)
Returns a source that will stream theEventJournalCacheEvent
events of a HazelcastICache
with the specified name.static <K, V> StreamSource<Map.Entry<K,V>>
Sources. mapJournal(IMap<? extends K,? extends V> map, JournalInitialPosition initialPos)
Convenience forSources.mapJournal(IMap, JournalInitialPosition, FunctionEx, PredicateEx)
which will pass onlyADDED
andUPDATED
events and will project the event's key and new value into aMap.Entry
.static <T, K, V> StreamSource<T>
Sources. mapJournal(IMap<? extends K,? extends V> map, JournalInitialPosition initialPos, FunctionEx<? super EventJournalMapEvent<K,V>,? extends T> projectionFn, PredicateEx<? super EventJournalMapEvent<K,V>> predicateFn)
Returns a source that will streamEventJournalMapEvent
s of the given HazelcastIMap
.static <K, V> StreamSource<Map.Entry<K,V>>
Sources. mapJournal(String mapName, JournalInitialPosition initialPos)
Convenience forSources.mapJournal(String, JournalInitialPosition, FunctionEx, PredicateEx)
which will pass onlyADDED
andUPDATED
events and will project the event's key and new value into aMap.Entry
.static <T, K, V> StreamSource<T>
Sources. mapJournal(String mapName, JournalInitialPosition initialPos, FunctionEx<? super EventJournalMapEvent<K,V>,? extends T> projectionFn, PredicateEx<? super EventJournalMapEvent<K,V>> predicateFn)
Returns a source that will streamEventJournalMapEvent
s of the HazelcastIMap
with the specified name.static <K, V> StreamSource<Map.Entry<K,V>>
Sources. remoteCacheJournal(String cacheName, ClientConfig clientConfig, JournalInitialPosition initialPos)
Convenience forSources.remoteCacheJournal(String, ClientConfig, JournalInitialPosition, FunctionEx, PredicateEx)
which will pass onlyCREATED
andUPDATED
events and will project the event's key and new value into aMap.Entry
.static <T, K, V> StreamSource<T>
Sources. remoteCacheJournal(String cacheName, ClientConfig clientConfig, JournalInitialPosition initialPos, FunctionEx<? super EventJournalCacheEvent<K,V>,? extends T> projectionFn, PredicateEx<? super EventJournalCacheEvent<K,V>> predicateFn)
Returns a source that will stream theEventJournalCacheEvent
events of the HazelcastICache
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 forSources.remoteMapJournal(String, ClientConfig, JournalInitialPosition, FunctionEx, PredicateEx)
which will pass onlyADDED
andUPDATED
events and will project the event's key and new value into aMap.Entry
.static <T, K, V> StreamSource<T>
Sources. remoteMapJournal(String mapName, ClientConfig clientConfig, JournalInitialPosition initialPos, FunctionEx<? super EventJournalMapEvent<K,V>,? extends T> projectionFn, PredicateEx<? super EventJournalMapEvent<K,V>> predicateFn)
Returns a source that will stream theEventJournalMapEvent
events of the HazelcastIMap
with the specified name from a remote cluster.