com.hazelcast.map.impl.wan

Class MerkleTreeUpdaterRecordStoreMutationObserver<R extends com.hazelcast.map.impl.record.Record>

java.lang.Object

com.hazelcast.map.impl.wan.MerkleTreeUpdaterRecordStoreMutationObserver<R>

Type Parameters:

R - The type of the records in the RecordStore

All Implemented Interfaces:

com.hazelcast.map.impl.recordstore.RecordStoreMutationObserver<R>

public class MerkleTreeUpdaterRecordStoreMutationObserver<R extends com.hazelcast.map.impl.record.Record>
extends Object
implements com.hazelcast.map.impl.recordstore.RecordStoreMutationObserver<R>

RecordStoreMutationObserver instance, which updates the provided MerkleTree when updating the observed RecordStore

In this class we need the Java objects to be converted to Data in order to guarantee that the same hashcode is generated for the same payload in every mutation case. Without this conversion and with InMemoryFormat.OBJECT, for example onUpdateRecord(com.hazelcast.nio.serialization.Data, R, java.lang.Object) passes a Java object as oldValue and a HeapData as newValue to the MerkleTree. These two values generate different hash codes even if they represent the "same" value. These different hash codes lead to changing the corresponding branch of the Merkle tree even if the record is updated with the same value, which is seen by a false difference by the Merkle consistency check.

Constructor Summary

Constructors

Constructor and Description
MerkleTreeUpdaterRecordStoreMutationObserver(com.hazelcast.wan.merkletree.MerkleTree merkleTree, com.hazelcast.spi.serialization.SerializationService serializationService) Creates a MerkleTreeUpdaterRecordStoreMutationObserver instance

Method Summary

Modifier and Type	Method and Description
void	onClear()
void	onDestroy(boolean internal)
void	onEvictRecord(com.hazelcast.nio.serialization.Data key, R record)
void	onLoadRecord(com.hazelcast.nio.serialization.Data key, R record)
void	onPutRecord(com.hazelcast.nio.serialization.Data key, R record)
void	onRemoveRecord(com.hazelcast.nio.serialization.Data key, R record)
void	onReplicationPutRecord(com.hazelcast.nio.serialization.Data key, R record)
void	onReset()
void	onUpdateRecord(com.hazelcast.nio.serialization.Data key, R record, Object newValue)

Methods inherited from class java.lang.Object

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

Constructor Detail

MerkleTreeUpdaterRecordStoreMutationObserver

public MerkleTreeUpdaterRecordStoreMutationObserver(com.hazelcast.wan.merkletree.MerkleTree merkleTree,
                                                    com.hazelcast.spi.serialization.SerializationService serializationService)

Creates a MerkleTreeUpdaterRecordStoreMutationObserver instance

Parameters:

merkleTree - The Merkle tree to update

serializationService - The serialization service used for Data conversion

Method Detail

onClear

public void onClear()

Specified by:

onClear in interface com.hazelcast.map.impl.recordstore.RecordStoreMutationObserver<R extends com.hazelcast.map.impl.record.Record>

onPutRecord

public void onPutRecord(com.hazelcast.nio.serialization.Data key,
                        R record)

Specified by:

onPutRecord in interface com.hazelcast.map.impl.recordstore.RecordStoreMutationObserver<R extends com.hazelcast.map.impl.record.Record>

onReplicationPutRecord

public void onReplicationPutRecord(com.hazelcast.nio.serialization.Data key,
                                   R record)

Specified by:

onReplicationPutRecord in interface com.hazelcast.map.impl.recordstore.RecordStoreMutationObserver<R extends com.hazelcast.map.impl.record.Record>

onUpdateRecord

public void onUpdateRecord(com.hazelcast.nio.serialization.Data key,
                           R record,
                           Object newValue)

Specified by:

onUpdateRecord in interface com.hazelcast.map.impl.recordstore.RecordStoreMutationObserver<R extends com.hazelcast.map.impl.record.Record>

onRemoveRecord

public void onRemoveRecord(com.hazelcast.nio.serialization.Data key,
                           R record)

Specified by:

onRemoveRecord in interface com.hazelcast.map.impl.recordstore.RecordStoreMutationObserver<R extends com.hazelcast.map.impl.record.Record>

onEvictRecord

public void onEvictRecord(com.hazelcast.nio.serialization.Data key,
                          R record)

Specified by:

onEvictRecord in interface com.hazelcast.map.impl.recordstore.RecordStoreMutationObserver<R extends com.hazelcast.map.impl.record.Record>

onLoadRecord

public void onLoadRecord(com.hazelcast.nio.serialization.Data key,
                         R record)

Specified by:

onLoadRecord in interface com.hazelcast.map.impl.recordstore.RecordStoreMutationObserver<R extends com.hazelcast.map.impl.record.Record>

onDestroy

public void onDestroy(boolean internal)

Specified by:

onDestroy in interface com.hazelcast.map.impl.recordstore.RecordStoreMutationObserver<R extends com.hazelcast.map.impl.record.Record>

onReset

public void onReset()

Specified by:

onReset in interface com.hazelcast.map.impl.recordstore.RecordStoreMutationObserver<R extends com.hazelcast.map.impl.record.Record>