Package com.hazelcast.jet.pipeline

Interface JournalSourceEntry<K,V>

Type Parameters:
K - the key type
V - the value type
All Superinterfaces:
Map.Entry<K,V>
public interface JournalSourceEntry<K,V> extends Map.Entry<K,V>
Entry emitted by journal sources such as Sources.mapJournalEntries(String, JournalInitialPosition), Sources.cacheJournalEntries(String, JournalInitialPosition), and others.

This interface extends Map.Entry and provides additional metadata about the journaled entry. In particular, it exposes whether any events were lost before this entry due to an event journal overflow.

Since:
5.7

  • Method Details

    • isAfterLostEvents

      boolean isAfterLostEvents()
      Indicates whether some events preceding this event were lost.
      Returns:
      true if events were lost, false otherwise