com.hazelcast.map.impl.recordstore

Class JsonMetadataRecordStoreMutationObserver

java.lang.Object

com.hazelcast.map.impl.recordstore.JsonMetadataRecordStoreMutationObserver

All Implemented Interfaces:

RecordStoreMutationObserver<Record>

public class JsonMetadataRecordStoreMutationObserver
extends Object
implements RecordStoreMutationObserver<Record>

Creates json related metadata for map records. Metadata is created and set for put and update operations. There is no need for removing metadata on remove events because metadata is stored inside record. It is removed with the record.

Constructor Summary

Constructors

Constructor and Description
JsonMetadataRecordStoreMutationObserver(InternalSerializationService serializationService, MetadataInitializer metadataInitializer)

Method Summary

Modifier and Type	Method and Description
protected Metadata	getMetadata(Record record)
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
protected void	removeMetadata(Record record)
protected void	setMetadata(Record record, Metadata metadata)

Methods inherited from class java.lang.Object

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

Constructor Detail

JsonMetadataRecordStoreMutationObserver

public JsonMetadataRecordStoreMutationObserver(InternalSerializationService serializationService,
                                               MetadataInitializer metadataInitializer)

Method Detail

onClear

public void onClear()

Description copied from interface: RecordStoreMutationObserver

Called if the observed RecordStore is cleared

Specified by:

onClear in interface RecordStoreMutationObserver<Record>

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<Record>

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<Record>

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<Record>

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<Record>

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<Record>

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<Record>

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<Record>

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<Record>

getMetadata

protected Metadata getMetadata(Record record)

setMetadata

protected void setMetadata(Record record,
                           Metadata metadata)

removeMetadata

protected void removeMetadata(Record record)