Uses of Interface
com.hazelcast.cache.journal.EventJournalCacheEvent

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

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

Modifier and Type	Method and Description
static <K,V> DistributedFunction<EventJournalCacheEvent<K,V>,Map.Entry<K,V>>	Util.cacheEventToEntry() Returns a projection that converts the EventJournalCacheEvent to a Map.Entry using the event's new value as a value.
static <K,V> DistributedPredicate<EventJournalCacheEvent<K,V>>	Util.cachePutEvents() Returns a predicate for Sources.cacheJournal(java.lang.String, com.hazelcast.jet.function.DistributedPredicate<com.hazelcast.cache.journal.EventJournalCacheEvent<K, V>>, com.hazelcast.jet.function.DistributedFunction<com.hazelcast.cache.journal.EventJournalCacheEvent<K, V>, T>, com.hazelcast.jet.pipeline.JournalInitialPosition) and Sources.remoteCacheJournal(java.lang.String, com.hazelcast.client.config.ClientConfig, com.hazelcast.jet.function.DistributedPredicate<com.hazelcast.cache.journal.EventJournalCacheEvent<K, V>>, com.hazelcast.jet.function.DistributedFunction<com.hazelcast.cache.journal.EventJournalCacheEvent<K, V>, T>, com.hazelcast.jet.pipeline.JournalInitialPosition) that passes only CREATED and UPDATED events.

Uses of EventJournalCacheEvent in com.hazelcast.jet.core.processor

Method parameters in com.hazelcast.jet.core.processor with type arguments of type EventJournalCacheEvent

Modifier and Type	Method and Description
static <T,K,V> ProcessorMetaSupplier	SourceProcessors.streamCacheP(String cacheName, DistributedPredicate<EventJournalCacheEvent<K,V>> predicateFn, DistributedFunction<EventJournalCacheEvent<K,V>,T> projectionFn, JournalInitialPosition initialPos, WatermarkGenerationParams<T> wmGenParams) Returns a supplier of processors for Sources.cacheJournal(String, DistributedPredicate, DistributedFunction, JournalInitialPosition).
static <T,K,V> ProcessorMetaSupplier	SourceProcessors.streamCacheP(String cacheName, DistributedPredicate<EventJournalCacheEvent<K,V>> predicateFn, DistributedFunction<EventJournalCacheEvent<K,V>,T> projectionFn, JournalInitialPosition initialPos, WatermarkGenerationParams<T> wmGenParams) Returns a supplier of processors for Sources.cacheJournal(String, DistributedPredicate, DistributedFunction, JournalInitialPosition).
static <T,K,V> ProcessorMetaSupplier	SourceProcessors.streamRemoteCacheP(String cacheName, ClientConfig clientConfig, DistributedPredicate<EventJournalCacheEvent<K,V>> predicateFn, DistributedFunction<EventJournalCacheEvent<K,V>,T> projectionFn, JournalInitialPosition initialPos, WatermarkGenerationParams<T> wmGenParams) Returns a supplier of processors for Sources.remoteCacheJournal(String, ClientConfig, DistributedPredicate, DistributedFunction, JournalInitialPosition).
static <T,K,V> ProcessorMetaSupplier	SourceProcessors.streamRemoteCacheP(String cacheName, ClientConfig clientConfig, DistributedPredicate<EventJournalCacheEvent<K,V>> predicateFn, DistributedFunction<EventJournalCacheEvent<K,V>,T> projectionFn, JournalInitialPosition initialPos, WatermarkGenerationParams<T> wmGenParams) Returns a supplier of processors for Sources.remoteCacheJournal(String, ClientConfig, DistributedPredicate, DistributedFunction, JournalInitialPosition).

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 and Description
static <T,K,V> StreamSource<T>	Sources.cacheJournal(String cacheName, DistributedPredicate<EventJournalCacheEvent<K,V>> predicateFn, DistributedFunction<EventJournalCacheEvent<K,V>,T> projectionFn, JournalInitialPosition initialPos) Returns a source that will stream the EventJournalCacheEvent events of the Hazelcast ICache with the specified name.
static <T,K,V> StreamSource<T>	Sources.cacheJournal(String cacheName, DistributedPredicate<EventJournalCacheEvent<K,V>> predicateFn, DistributedFunction<EventJournalCacheEvent<K,V>,T> projectionFn, JournalInitialPosition initialPos) Returns a source that will stream the EventJournalCacheEvent events of the Hazelcast ICache with the specified name.
static <T,K,V> StreamSource<T>	Sources.remoteCacheJournal(String cacheName, ClientConfig clientConfig, DistributedPredicate<EventJournalCacheEvent<K,V>> predicateFn, DistributedFunction<EventJournalCacheEvent<K,V>,T> projectionFn, JournalInitialPosition initialPos) Returns a source that will stream the EventJournalCacheEvent events of the Hazelcast ICache with the specified name from a remote cluster.
static <T,K,V> StreamSource<T>	Sources.remoteCacheJournal(String cacheName, ClientConfig clientConfig, DistributedPredicate<EventJournalCacheEvent<K,V>> predicateFn, DistributedFunction<EventJournalCacheEvent<K,V>,T> projectionFn, JournalInitialPosition initialPos) Returns a source that will stream the EventJournalCacheEvent events of the Hazelcast ICache with the specified name from a remote cluster.