com.hazelcast.map.impl.recordstore

Class EventJournalWriterRecordStoreMutationObserver

java.lang.Object

com.hazelcast.map.impl.recordstore.EventJournalWriterRecordStoreMutationObserver

All Implemented Interfaces:

RecordStoreMutationObserver

public class EventJournalWriterRecordStoreMutationObserver
extends Object
implements RecordStoreMutationObserver

Constructor Summary

Constructors

Constructor and Description
EventJournalWriterRecordStoreMutationObserver(MapEventJournal eventJournal, MapContainer mapContainer, int partitionId)

Method Summary

Modifier and Type	Method and Description
void	onClear() Called if the observed RecordStore is cleared
void	onDestroy(boolean internal) Called when the observed RecordStore is being destroyed.
void	onEvictRecord(Data key, Record record) Called when a record is evicted from the observed RecordStore
void	onLoadRecord(Data key, Record record) Called when a record is loaded into the observed RecordStore
void	onPutRecord(Data key, Record record) Called when a new record is added to the RecordStore
void	onRemoveRecord(Data key, Record record) Called when a record is removed from the observed RecordStore
void	onReplicationPutRecord(Data key, Record record) Called when a new record is added to the RecordStore due to replication
void	onReset() Called when the observed RecordStore is being reset.
void	onUpdateRecord(Data key, Record record, Object newValue) Called when a new record is updated in the observed RecordStore

Methods inherited from class java.lang.Object

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

Constructor Detail

EventJournalWriterRecordStoreMutationObserver

public EventJournalWriterRecordStoreMutationObserver(MapEventJournal eventJournal,
                                                     MapContainer mapContainer,
                                                     int partitionId)

Method Detail

onClear

public void onClear()

Description copied from interface: RecordStoreMutationObserver

Called if the observed RecordStore is cleared

Specified by:

onClear in interface RecordStoreMutationObserver

onPutRecord

public void onPutRecord(Data key,
                        Record record)

Description copied from interface: RecordStoreMutationObserver

Called when a new record is added to the RecordStore

Specified by:

onPutRecord in interface RecordStoreMutationObserver

Parameters:

key - The key of the record

record - The record

onReplicationPutRecord

public void onReplicationPutRecord(Data key,
                                   Record record)

Description copied from interface: RecordStoreMutationObserver

Called when a new record is added to the RecordStore due to replication

Specified by:

onReplicationPutRecord in interface RecordStoreMutationObserver

Parameters:

key - The key of the record

record - The record

onUpdateRecord

public void onUpdateRecord(Data key,
                           Record record,
                           Object newValue)

Description copied from interface: RecordStoreMutationObserver

Called when a new record is updated in the observed RecordStore

Specified by:

onUpdateRecord in interface RecordStoreMutationObserver

Parameters:

key - The key of the record

record - The record

newValue - The new value of the record

onRemoveRecord

public void onRemoveRecord(Data key,
                           Record record)

Description copied from interface: RecordStoreMutationObserver

Called when a record is removed from the observed RecordStore

Specified by:

onRemoveRecord in interface RecordStoreMutationObserver

Parameters:

key - The key of the record

record - The record

onEvictRecord

public void onEvictRecord(Data key,
                          Record record)

Description copied from interface: RecordStoreMutationObserver

Called when a record is evicted from the observed RecordStore

Specified by:

onEvictRecord in interface RecordStoreMutationObserver

Parameters:

key - The key of the record

record - The record

onLoadRecord

public void onLoadRecord(Data key,
                         Record record)

Description copied from interface: RecordStoreMutationObserver

Called when a record is loaded into the observed RecordStore

Specified by:

onLoadRecord in interface RecordStoreMutationObserver

Parameters:

key - The key of the record

record - The record

onDestroy

public void onDestroy(boolean internal)

Description copied from interface: RecordStoreMutationObserver

Called when the observed RecordStore is being destroyed. The observer should release all resources. The implementations of this method should be idempotent.

Specified by:

onDestroy in interface RecordStoreMutationObserver

Parameters:

internal - is only data bound to the MapService being destroyed

onReset

public void onReset()

Description copied from interface: RecordStoreMutationObserver

Called when the observed RecordStore is being reset.

Specified by:

onReset in interface RecordStoreMutationObserver