Uses of Interface
com.hazelcast.map.EventJournalMapEvent

Packages that use 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

Methods in com.hazelcast.jet that return types with arguments of type EventJournalMapEvent

Modifier and Type	Method and Description
static <K,V> FunctionEx<EventJournalMapEvent<K,V>,V>	Util.mapEventNewValue() Returns a projection that extracts the new value from an EventJournalMapEvent.
static <K,V> FunctionEx<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> PredicateEx<EventJournalMapEvent<K,V>>	Util.mapPutEvents() Returns a predicate for Sources.mapJournal(java.lang.String, com.hazelcast.jet.pipeline.JournalInitialPosition, com.hazelcast.function.FunctionEx<? super com.hazelcast.map.EventJournalMapEvent<K, V>, ? extends T>, com.hazelcast.function.PredicateEx<? super com.hazelcast.map.EventJournalMapEvent<K, V>>) and Sources.remoteMapJournal(java.lang.String, com.hazelcast.client.config.ClientConfig, com.hazelcast.jet.pipeline.JournalInitialPosition, com.hazelcast.function.FunctionEx<? super com.hazelcast.map.EventJournalMapEvent<K, V>, ? extends T>, com.hazelcast.function.PredicateEx<? super com.hazelcast.map.EventJournalMapEvent<K, V>>) 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, 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, JournalInitialPosition, FunctionEx, PredicateEx).
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, JournalInitialPosition, FunctionEx, PredicateEx).
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, JournalInitialPosition, FunctionEx, PredicateEx).
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, JournalInitialPosition, FunctionEx, PredicateEx).

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, JournalInitialPosition initialPos, FunctionEx<? super EventJournalMapEvent<K,V>,? extends T> projectionFn, PredicateEx<? super EventJournalMapEvent<K,V>> predicateFn) Returns a source that will stream EventJournalMapEvents of the given Hazelcast IMap.
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 stream EventJournalMapEvents of the given Hazelcast IMap.
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 stream EventJournalMapEvents of the Hazelcast IMap 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 stream EventJournalMapEvents of the Hazelcast IMap 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 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, JournalInitialPosition initialPos, FunctionEx<? super EventJournalMapEvent<K,V>,? extends T> projectionFn, PredicateEx<? super EventJournalMapEvent<K,V>> predicateFn) 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, DataConnectionRef dataConnectionRef, JournalInitialPosition initialPos, FunctionEx<? super EventJournalMapEvent<K,V>,? extends T> projectionFn, PredicateEx<? super EventJournalMapEvent<K,V>> predicateFn) The same as the Sources.remoteMapJournal(String, ClientConfig, JournalInitialPosition, FunctionEx, PredicateEx) method.
static <T,K,V> StreamSource<T>	Sources.remoteMapJournal(String mapName, DataConnectionRef dataConnectionRef, JournalInitialPosition initialPos, FunctionEx<? super EventJournalMapEvent<K,V>,? extends T> projectionFn, PredicateEx<? super EventJournalMapEvent<K,V>> predicateFn) The same as the Sources.remoteMapJournal(String, ClientConfig, JournalInitialPosition, FunctionEx, PredicateEx) method.