public class JsonMetadataRecordStoreMutationObserver extends Object implements RecordStoreMutationObserver<Record>
Constructor and Description |
---|
JsonMetadataRecordStoreMutationObserver(InternalSerializationService serializationService,
MetadataInitializer metadataInitializer) |
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) |
public JsonMetadataRecordStoreMutationObserver(InternalSerializationService serializationService, MetadataInitializer metadataInitializer)
public void onClear()
RecordStoreMutationObserver
RecordStore
is clearedonClear
in interface RecordStoreMutationObserver<Record>
public void onPutRecord(Data key, Record record)
RecordStoreMutationObserver
RecordStore
onPutRecord
in interface RecordStoreMutationObserver<Record>
key
- The key of the recordrecord
- The recordpublic void onReplicationPutRecord(Data key, Record record)
RecordStoreMutationObserver
RecordStore
due
to replicationonReplicationPutRecord
in interface RecordStoreMutationObserver<Record>
key
- The key of the recordrecord
- The recordpublic void onUpdateRecord(Data key, Record record, Object newValue)
RecordStoreMutationObserver
RecordStore
onUpdateRecord
in interface RecordStoreMutationObserver<Record>
key
- The key of the recordrecord
- The recordnewValue
- The new value of the recordpublic void onRemoveRecord(Data key, Record record)
RecordStoreMutationObserver
RecordStore
onRemoveRecord
in interface RecordStoreMutationObserver<Record>
key
- The key of the recordrecord
- The recordpublic void onEvictRecord(Data key, Record record)
RecordStoreMutationObserver
RecordStore
onEvictRecord
in interface RecordStoreMutationObserver<Record>
key
- The key of the recordrecord
- The recordpublic void onLoadRecord(Data key, Record record)
RecordStoreMutationObserver
RecordStore
onLoadRecord
in interface RecordStoreMutationObserver<Record>
key
- The key of the recordrecord
- The recordpublic void onDestroy(boolean internal)
RecordStoreMutationObserver
RecordStore
is being destroyed.
The observer should release all resources. The implementations of
this method should be idempotent.onDestroy
in interface RecordStoreMutationObserver<Record>
internal
- is only data bound to the MapService
being destroyedpublic void onReset()
RecordStoreMutationObserver
RecordStore
is being reset.onReset
in interface RecordStoreMutationObserver<Record>
protected void removeMetadata(Record record)
Copyright © 2021 Hazelcast, Inc.. All Rights Reserved.