Uses of Interface
com.hazelcast.cache.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
-
Uses of EventJournalCacheEvent in com.hazelcast.jet.core.processor
-
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 Description 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 <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 <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 <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.