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