Uses of Interface
com.hazelcast.jet.pipeline.JournalSourceEntry

Packages that use JournalSourceEntry

Package	Description
com.hazelcast.jet	Hazelcast Jet is a distributed computation engine running on top of Hazelcast IMDG technology.
com.hazelcast.jet.pipeline	The Pipeline API is Jet's high-level API to build and execute distributed computation jobs.

Uses of JournalSourceEntry in com.hazelcast.jet

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

Modifier and Type	Method	Description
static <K, V> FunctionEx<EventJournalCacheEvent<K,V>,JournalSourceEntry<K,V>>	Util.cacheEventToJournalEntry()	Returns a projection that converts the EventJournalCacheEvent to a JournalSourceEntry using the event's new value as a value.
static <K, V> FunctionEx<EventJournalMapEvent<K,V>,JournalSourceEntry<K,V>>	Util.mapEventToJournalEntry()	Returns a projection that converts the EventJournalMapEvent to a JournalSourceEntry using the event's new value as a value.

Uses of JournalSourceEntry in com.hazelcast.jet.pipeline

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

Modifier and Type	Method	Description
static <K, V> StreamSource<JournalSourceEntry<K,V>>	Sources.cacheJournalEntries(String cacheName, JournalInitialPosition initialPos)	Same as Sources.cacheJournal(String, JournalInitialPosition), but returns JournalSourceEntry, which provides information about whether dropped events occurred in the journal.
static <K, V> StreamSource<JournalSourceEntry<K,V>>	Sources.mapJournalEntries(IMap<? extends K,? extends V> map, JournalInitialPosition initialPos)	Same as Sources.mapJournal(IMap, JournalInitialPosition), but returns JournalSourceEntry, which provides information about whether dropped events occurred in the journal.
static <K, V> StreamSource<JournalSourceEntry<K,V>>	Sources.mapJournalEntries(String mapName, JournalInitialPosition initialPos)	Same as Sources.mapJournal(String, JournalInitialPosition), but returns JournalSourceEntry, which provides information about whether dropped events occurred in the journal.
static <K, V> StreamSource<JournalSourceEntry<K,V>>	Sources.remoteCacheJournalEntries(String cacheName, ClientConfig clientConfig, JournalInitialPosition initialPos)	Same as Sources.remoteCacheJournal(String, ClientConfig, JournalInitialPosition), but returns JournalSourceEntry, which provides information about whether dropped events occurred in the journal.
static <K, V> StreamSource<JournalSourceEntry<K,V>>	Sources.remoteMapJournalEntries(String mapName, ClientConfig clientConfig, JournalInitialPosition initialPos)	Same as Sources.remoteMapJournal(String, ClientConfig, JournalInitialPosition), but returns JournalSourceEntry, which provides information about whether dropped events occurred in the journal.
static <K, V> StreamSource<JournalSourceEntry<K,V>>	Sources.remoteMapJournalEntries(String mapName, DataConnectionRef dataConnectionRef, JournalInitialPosition initialPos)	Same as Sources.remoteMapJournal(String, DataConnectionRef, JournalInitialPosition), but returns JournalSourceEntry, which provides information about whether dropped events occurred in the journal.