com.hazelcast.map.impl.wan

Class MapReplicationUpdate

java.lang.Object

com.hazelcast.map.impl.wan.MapReplicationUpdate

All Implemented Interfaces:

DataSerializable, IdentifiedDataSerializable, InternalWanReplicationEvent, WanReplicationEvent

public class MapReplicationUpdate
extends Object
implements InternalWanReplicationEvent, IdentifiedDataSerializable

WAN replication object for map update operations.

Constructor Summary

Constructors

Constructor and Description
MapReplicationUpdate()
MapReplicationUpdate(String mapName, SplitBrainMergePolicy mergePolicy, EntryView<Data,Data> entryView)

Method Summary

Modifier and Type	Method and Description
int	getBackupCount() Returns the backup count (sync and async) for this WAN event.
int	getClassId() Returns type identifier for this class.
Set<String>	getClusterNames() Returns the set of cluster names on which this event has already been processed.
long	getCreationTime() Returns the creation time for this event in milliseconds.
WanMapEntryView<Data,Data>	getEntryView()
int	getFactoryId() Returns DataSerializableFactory factory ID for this class.
Data	getKey() Returns the key for the entry on which the event occurred.
SplitBrainMergePolicy	getMergePolicy()
String	getObjectName() Returns the name of the distributed object (map or cache) on which this event occurred.
String	getServiceName() Returns the service name on which this event occurred.
void	incrementEventCount(DistributedServiceWanEventCounters counters) Increments the count for the related event in the counters
void	readData(ObjectDataInput in) Reads fields from the input stream
void	setEntryView(WanMapEntryView<Data,Data> entryView)
void	setMergePolicy(SplitBrainMergePolicy mergePolicy)
void	writeData(ObjectDataOutput out) Writes object fields to output stream

Methods inherited from class java.lang.Object

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

Constructor Detail

MapReplicationUpdate

public MapReplicationUpdate()

MapReplicationUpdate

public MapReplicationUpdate(String mapName,
                            SplitBrainMergePolicy mergePolicy,
                            EntryView<Data,Data> entryView)

Method Detail

getMergePolicy

public SplitBrainMergePolicy getMergePolicy()

setMergePolicy

public void setMergePolicy(SplitBrainMergePolicy mergePolicy)

getEntryView

public WanMapEntryView<Data,Data> getEntryView()

setEntryView

public void setEntryView(WanMapEntryView<Data,Data> entryView)

writeData

public void writeData(ObjectDataOutput out)
               throws IOException

Description copied from interface: DataSerializable

Writes object fields to output stream

Specified by:

writeData in interface DataSerializable

Parameters:

out - output

Throws:

IOException - if an I/O error occurs. In particular, an IOException may be thrown if the output stream has been closed.

readData

public void readData(ObjectDataInput in)
              throws IOException

Description copied from interface: DataSerializable

Reads fields from the input stream

Specified by:

readData in interface DataSerializable

Parameters:

in - input

Throws:

IOException - if an I/O error occurs. In particular, an IOException may be thrown if the input stream has been closed.

getFactoryId

public int getFactoryId()

Description copied from interface: IdentifiedDataSerializable

Returns DataSerializableFactory factory ID for this class.

Specified by:

getFactoryId in interface IdentifiedDataSerializable

Returns:

factory ID

getClassId

public int getClassId()

Description copied from interface: IdentifiedDataSerializable

Returns type identifier for this class. It should be unique per DataSerializableFactory.

Specified by:

getClassId in interface IdentifiedDataSerializable

Returns:

type ID

incrementEventCount

public void incrementEventCount(DistributedServiceWanEventCounters counters)

Description copied from interface: WanReplicationEvent

Increments the count for the related event in the counters

Specified by:

incrementEventCount in interface WanReplicationEvent

Parameters:

counters - the WAN event counter

getKey

@Nonnull
public Data getKey()

Description copied from interface: InternalWanReplicationEvent

Returns the key for the entry on which the event occurred.

Specified by:

getKey in interface InternalWanReplicationEvent

getClusterNames

@Nonnull
public Set<String> getClusterNames()

Description copied from interface: InternalWanReplicationEvent

Returns the set of cluster names on which this event has already been processed.

Specified by:

getClusterNames in interface InternalWanReplicationEvent

getBackupCount

public int getBackupCount()

Description copied from interface: InternalWanReplicationEvent

Returns the backup count (sync and async) for this WAN event.

Specified by:

getBackupCount in interface InternalWanReplicationEvent

getCreationTime

public long getCreationTime()

Description copied from interface: InternalWanReplicationEvent

Returns the creation time for this event in milliseconds.

Specified by:

getCreationTime in interface InternalWanReplicationEvent

See Also:

Clock.currentTimeMillis()

getServiceName

public String getServiceName()

Description copied from interface: WanReplicationEvent

Returns the service name on which this event occurred.

Specified by:

getServiceName in interface WanReplicationEvent

Returns:

the service name

getObjectName

public String getObjectName()

Description copied from interface: WanReplicationEvent

Returns the name of the distributed object (map or cache) on which this event occurred.

Specified by:

getObjectName in interface WanReplicationEvent

Returns:

the distributed object name