Uses of Interface
com.hazelcast.map.journal.EventJournalMapEvent

Packages that use EventJournalMapEvent

Package	Description
com.hazelcast.client.proxy	This package contains client side proxy implementations of the different Hazelcast data structures and operation types
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.client.proxy

Method parameters in com.hazelcast.client.proxy with type arguments of type EventJournalMapEvent

Modifier and Type	Method and Description
<T> ICompletableFuture<ReadResultSet<T>>	ClientMapProxy.readFromEventJournal(long startSequence, int minSize, int maxSize, int partitionId, Predicate<? super EventJournalMapEvent<K,V>> predicate, Projection<? super EventJournalMapEvent<K,V>,? extends T> projection)
<T> ICompletableFuture<ReadResultSet<T>>	ClientMapProxy.readFromEventJournal(long startSequence, int minSize, int maxSize, int partitionId, Predicate<? super EventJournalMapEvent<K,V>> predicate, Projection<? super EventJournalMapEvent<K,V>,? extends T> projection)

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> DistributedFunction<EventJournalMapEvent<K,V>,V>	Util.mapEventNewValue() Returns a projection that extracts the new value from a EventJournalMapEvent.
static <K,V> DistributedFunction<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> DistributedPredicate<EventJournalMapEvent<K,V>>	Util.mapPutEvents() Returns a predicate for Sources.mapJournal(java.lang.String, com.hazelcast.jet.function.DistributedPredicate<com.hazelcast.map.journal.EventJournalMapEvent<K, V>>, com.hazelcast.jet.function.DistributedFunction<com.hazelcast.map.journal.EventJournalMapEvent<K, V>, T>, com.hazelcast.jet.pipeline.JournalInitialPosition) and Sources.remoteMapJournal(java.lang.String, com.hazelcast.client.config.ClientConfig, com.hazelcast.jet.function.DistributedPredicate<com.hazelcast.map.journal.EventJournalMapEvent<K, V>>, com.hazelcast.jet.function.DistributedFunction<com.hazelcast.map.journal.EventJournalMapEvent<K, V>, T>, com.hazelcast.jet.pipeline.JournalInitialPosition) 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, DistributedPredicate<EventJournalMapEvent<K,V>> predicateFn, DistributedFunction<EventJournalMapEvent<K,V>,T> projectionFn, JournalInitialPosition initialPos, WatermarkGenerationParams<? super T> wmGenParams) Returns a supplier of processors for Sources.mapJournal(String, DistributedPredicate, DistributedFunction, JournalInitialPosition).
static <T,K,V> ProcessorMetaSupplier	SourceProcessors.streamMapP(String mapName, DistributedPredicate<EventJournalMapEvent<K,V>> predicateFn, DistributedFunction<EventJournalMapEvent<K,V>,T> projectionFn, JournalInitialPosition initialPos, WatermarkGenerationParams<? super T> wmGenParams) Returns a supplier of processors for Sources.mapJournal(String, DistributedPredicate, DistributedFunction, JournalInitialPosition).
static <T,K,V> ProcessorMetaSupplier	SourceProcessors.streamRemoteMapP(String mapName, ClientConfig clientConfig, DistributedPredicate<EventJournalMapEvent<K,V>> predicateFn, DistributedFunction<EventJournalMapEvent<K,V>,T> projectionFn, JournalInitialPosition initialPos, WatermarkGenerationParams<T> wmGenParams) Returns a supplier of processors for Sources.remoteMapJournal(String, ClientConfig, DistributedPredicate, DistributedFunction, JournalInitialPosition).
static <T,K,V> ProcessorMetaSupplier	SourceProcessors.streamRemoteMapP(String mapName, ClientConfig clientConfig, DistributedPredicate<EventJournalMapEvent<K,V>> predicateFn, DistributedFunction<EventJournalMapEvent<K,V>,T> projectionFn, JournalInitialPosition initialPos, WatermarkGenerationParams<T> wmGenParams) Returns a supplier of processors for Sources.remoteMapJournal(String, ClientConfig, DistributedPredicate, DistributedFunction, JournalInitialPosition).

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(String mapName, DistributedPredicate<EventJournalMapEvent<K,V>> predicateFn, DistributedFunction<EventJournalMapEvent<K,V>,T> projectionFn, JournalInitialPosition initialPos) 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, DistributedPredicate<EventJournalMapEvent<K,V>> predicateFn, DistributedFunction<EventJournalMapEvent<K,V>,T> projectionFn, JournalInitialPosition initialPos) 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, DistributedPredicate<EventJournalMapEvent<K,V>> predicateFn, DistributedFunction<EventJournalMapEvent<K,V>,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.
static <T,K,V> StreamSource<T>	Sources.remoteMapJournal(String mapName, ClientConfig clientConfig, DistributedPredicate<EventJournalMapEvent<K,V>> predicateFn, DistributedFunction<EventJournalMapEvent<K,V>,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.