com.hazelcast.map.impl.journal

Class RingbufferMapEventJournalImpl

java.lang.Object

com.hazelcast.map.impl.journal.RingbufferMapEventJournalImpl

All Implemented Interfaces:

EventJournal<InternalEventJournalMapEvent>, MapEventJournal

public class RingbufferMapEventJournalImpl
extends Object
implements MapEventJournal

The map event journal implementation based on the Ringbuffer. It will add all journal events into a RingbufferContainer with the provided namespace and partition ID and allows checking if the map has a configured event journal. Adapts the EventJournalConfig to the RingbufferConfig when creating the ringbuffer.

Constructor Summary

Constructors

Constructor and Description
RingbufferMapEventJournalImpl(NodeEngine engine)

Method Summary

Modifier and Type	Method and Description
void	cleanup(ObjectNamespace namespace, int partitionId) Cleans up the event journal by removing any expired items.
void	destroy(ObjectNamespace namespace, int partitionId) Destroys the event journal for the given object and partition ID.
EventJournalConfig	getEventJournalConfig(ObjectNamespace namespace)
WaitNotifyKey	getWaitNotifyKey(ObjectNamespace namespace, int partitionId) Return the WaitNotifyKey for objects waiting and notifying on the event journal.
boolean	hasEventJournal(ObjectNamespace namespace) Returns true if the object has a configured and enabled event journal.
void	isAvailableOrNextSequence(ObjectNamespace namespace, int partitionId, long sequence) Checks if the sequence is of an item that can be read immediately or is the sequence of the next item to be added into the event journal.
boolean	isNextAvailableSequence(ObjectNamespace namespace, int partitionId, long sequence) Checks if the sequence is the sequence of the next event to be added to the event journal.
long	newestSequence(ObjectNamespace namespace, int partitionId) Returns the sequence of the newest event stored in the event journal.
long	oldestSequence(ObjectNamespace namespace, int partitionId) Returns the sequence of the oldest event stored in the event journal.
<T> long	readMany(ObjectNamespace namespace, int partitionId, long beginSequence, ReadResultSetImpl<InternalEventJournalMapEvent,T> resultSet) Reads events from the journal in batches.
RingbufferConfig	toRingbufferConfig(EventJournalConfig config)
void	writeAddEvent(ObjectNamespace namespace, int partitionId, Data key, Object value) Writes an EntryEventType.ADDED to the event journal.
void	writeEvictEvent(ObjectNamespace namespace, int partitionId, Data key, Object value) Writes an EntryEventType.EVICTED to the event journal.
void	writeRemoveEvent(ObjectNamespace namespace, int partitionId, Data key, Object value) Writes an EntryEventType.REMOVED to the event journal.
void	writeUpdateEvent(ObjectNamespace namespace, int partitionId, Data key, Object oldValue, Object newValue) Writes an EntryEventType.UPDATED to the event journal.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RingbufferMapEventJournalImpl

public RingbufferMapEventJournalImpl(NodeEngine engine)

Method Detail

writeUpdateEvent

public void writeUpdateEvent(ObjectNamespace namespace,
                             int partitionId,
                             Data key,
                             Object oldValue,
                             Object newValue)

Description copied from interface: MapEventJournal

Writes an EntryEventType.UPDATED to the event journal. If there is no event journal configured for this map, the method will do nothing. If an event is added to the event journal, all parked operations waiting for new events on that journal will be unparked.

Specified by:

writeUpdateEvent in interface MapEventJournal

Parameters:

namespace - the map namespace

partitionId - the entry key partition

key - the entry key

oldValue - the old value

newValue - the new value

writeAddEvent

public void writeAddEvent(ObjectNamespace namespace,
                          int partitionId,
                          Data key,
                          Object value)

Description copied from interface: MapEventJournal

Writes an EntryEventType.ADDED to the event journal. If there is no event journal configured for this map, the method will do nothing. If an event is added to the event journal, all parked operations waiting for new events on that journal will be unparked.

Specified by:

writeAddEvent in interface MapEventJournal

Parameters:

namespace - the map namespace

partitionId - the entry key partition

key - the entry key

value - the entry value

writeRemoveEvent

public void writeRemoveEvent(ObjectNamespace namespace,
                             int partitionId,
                             Data key,
                             Object value)

Description copied from interface: MapEventJournal

Writes an EntryEventType.REMOVED to the event journal. If there is no event journal configured for this map, the method will do nothing. If an event is added to the event journal, all parked operations waiting for new events on that journal will be unparked.

Specified by:

writeRemoveEvent in interface MapEventJournal

Parameters:

namespace - the map namespace

partitionId - the entry key partition

key - the entry key

value - the entry value

writeEvictEvent

public void writeEvictEvent(ObjectNamespace namespace,
                            int partitionId,
                            Data key,
                            Object value)

Description copied from interface: MapEventJournal

Writes an EntryEventType.EVICTED to the event journal. If there is no event journal configured for this map, the method will do nothing. If an event is added to the event journal, all parked operations waiting for new events on that journal will be unparked.

Specified by:

writeEvictEvent in interface MapEventJournal

Parameters:

namespace - the map namespace

partitionId - the entry key partition

key - the entry key

value - the entry value

newestSequence

public long newestSequence(ObjectNamespace namespace,
                           int partitionId)

Description copied from interface: EventJournal

Returns the sequence of the newest event stored in the event journal.

Specified by:

newestSequence in interface EventJournal<InternalEventJournalMapEvent>

Parameters:

namespace - the object namespace

partitionId - the partition ID of the event journal

Returns:

the sequence of the last stored event

oldestSequence

public long oldestSequence(ObjectNamespace namespace,
                           int partitionId)

Description copied from interface: EventJournal

Returns the sequence of the oldest event stored in the event journal.

Specified by:

oldestSequence in interface EventJournal<InternalEventJournalMapEvent>

Parameters:

namespace - the object namespace

partitionId - the partition ID of the event journal

Returns:

the sequence of the oldest stored event

destroy

public void destroy(ObjectNamespace namespace,
                    int partitionId)

Description copied from interface: EventJournal

Destroys the event journal for the given object and partition ID.

Specified by:

destroy in interface EventJournal<InternalEventJournalMapEvent>

Parameters:

namespace - the object namespace

partitionId - the partition ID of the entries in the journal

isAvailableOrNextSequence

public void isAvailableOrNextSequence(ObjectNamespace namespace,
                                      int partitionId,
                                      long sequence)

Description copied from interface: EventJournal

Checks if the sequence is of an item that can be read immediately or is the sequence of the next item to be added into the event journal. Since this method allows the sequence to be one larger than the EventJournal.newestSequence(ObjectNamespace, int), the caller can use this method to check the sequence before performing a possibly blocking read.

Specified by:

isAvailableOrNextSequence in interface EventJournal<InternalEventJournalMapEvent>

Parameters:

namespace - the object namespace

partitionId - the partition ID of the entries in the journal

sequence - the sequence wanting to be read

isNextAvailableSequence

public boolean isNextAvailableSequence(ObjectNamespace namespace,
                                       int partitionId,
                                       long sequence)

Description copied from interface: EventJournal

Checks if the sequence is the sequence of the next event to be added to the event journal.

Specified by:

isNextAvailableSequence in interface EventJournal<InternalEventJournalMapEvent>

Parameters:

namespace - the object namespace

partitionId - the partition ID of the entries in the journal

sequence - the sequence to be checked

Returns:

true if the sequence is one greater than the sequence of the last event, false otherwise

getWaitNotifyKey

public WaitNotifyKey getWaitNotifyKey(ObjectNamespace namespace,
                                      int partitionId)

Description copied from interface: EventJournal

Return the WaitNotifyKey for objects waiting and notifying on the event journal.

Specified by:

getWaitNotifyKey in interface EventJournal<InternalEventJournalMapEvent>

Parameters:

namespace - the object namespace

partitionId - the partition ID of the entries in the journal

Returns:

the key for a wait notify object

readMany

public <T> long readMany(ObjectNamespace namespace,
                         int partitionId,
                         long beginSequence,
                         ReadResultSetImpl<InternalEventJournalMapEvent,T> resultSet)

Description copied from interface: EventJournal

Reads events from the journal in batches. It will read up to the maximum number that the set can hold - see ReadResultSetImpl.isMaxSizeReached() or until the journal is exhausted. The resultSet allows filtering and projections on journal items so that the caller can control which data is returned.

If the set has reached it's max size, the returned sequence one greater than the sequence of the last item in the set. In other cases it means that the set hasn't reached it's full size because we have reached the end of the event journal. In this case the returned sequence is one greater than the sequence of the last stored event.

Specified by:

readMany in interface EventJournal<InternalEventJournalMapEvent>

Type Parameters:

T - the return type of the projected events

Parameters:

namespace - the object namespace

partitionId - the partition ID of the entries in the journal

beginSequence - the sequence of the first item to read.

resultSet - the container for read, filtered and projected events

Returns:

returns the sequenceId of the next item to read

See Also:

EventJournal.isAvailableOrNextSequence(ObjectNamespace, int, long)

cleanup

public void cleanup(ObjectNamespace namespace,
                    int partitionId)

Description copied from interface: EventJournal

Cleans up the event journal by removing any expired items. Items are considered expired as according to the configured expiration policy.

Specified by:

cleanup in interface EventJournal<InternalEventJournalMapEvent>

Parameters:

namespace - the object namespace

partitionId - the partition ID of the entries in the journal

hasEventJournal

public boolean hasEventJournal(ObjectNamespace namespace)

Description copied from interface: MapEventJournal

Returns true if the object has a configured and enabled event journal.

Specified by:

hasEventJournal in interface EventJournal<InternalEventJournalMapEvent>

Specified by:

hasEventJournal in interface MapEventJournal

Parameters:

namespace - the object namespace

Returns:

true if the object has a configured and enabled event journal, false otherwise

getEventJournalConfig

public EventJournalConfig getEventJournalConfig(ObjectNamespace namespace)

Specified by:

getEventJournalConfig in interface EventJournal<InternalEventJournalMapEvent>

toRingbufferConfig

public RingbufferConfig toRingbufferConfig(EventJournalConfig config)

Specified by:

toRingbufferConfig in interface EventJournal<InternalEventJournalMapEvent>