com.hazelcast.internal.partition

Class ReplicaMigrationEventImpl

java.lang.Object

com.hazelcast.internal.partition.ReplicaMigrationEventImpl

All Implemented Interfaces:

DataSerializable, IdentifiedDataSerializable, PartitionEvent, ReplicaMigrationEvent

public class ReplicaMigrationEventImpl
extends Object
implements ReplicaMigrationEvent, IdentifiedDataSerializable

An event fired when a partition migration starts, completes or fails.

See Also:

Partition, PartitionService, MigrationListener

Constructor Summary

Constructors

Constructor and Description
ReplicaMigrationEventImpl()
ReplicaMigrationEventImpl(MigrationState state, int partitionId, int replicaIndex, Member source, Member destination, boolean success, long elapsedTime)

Method Summary

Modifier and Type	Method and Description
int	getClassId() Returns type identifier for this class.
Member	getDestination() Returns the new owner of the migrating partition replica.
long	getElapsedTime() Returns the elapsed the time of this migration in milliseconds.
int	getFactoryId() Returns DataSerializableFactory factory ID for this class.
MigrationState	getMigrationState() Returns the progress information of the overall migration.
int	getPartitionId() Returns the partition ID that the event is dispatched for.
int	getReplicaIndex() Returns the index of the partition replica.
Member	getSource() Returns the old owner of the migrating partition replica.
boolean	isSuccess() Returns the result of the migration: completed or failed.
void	readData(ObjectDataInput in) Reads fields from the input stream
String	toString()
void	writeData(ObjectDataOutput out) Writes object fields to output stream

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicaMigrationEventImpl

public ReplicaMigrationEventImpl()

ReplicaMigrationEventImpl

public ReplicaMigrationEventImpl(MigrationState state,
                                 int partitionId,
                                 int replicaIndex,
                                 Member source,
                                 Member destination,
                                 boolean success,
                                 long elapsedTime)

Method Detail

getPartitionId

public int getPartitionId()

Description copied from interface: PartitionEvent

Returns the partition ID that the event is dispatched for.

Specified by:

getPartitionId in interface PartitionEvent

Returns:

the partition ID that the event is dispatched for

getReplicaIndex

public int getReplicaIndex()

Description copied from interface: ReplicaMigrationEvent

Returns the index of the partition replica. 0th index is primary replica, 1st index is 1st backup and so on.

Specified by:

getReplicaIndex in interface ReplicaMigrationEvent

Returns:

the index of the partition replica

getSource

public Member getSource()

Description copied from interface: ReplicaMigrationEvent

Returns the old owner of the migrating partition replica.

Specified by:

getSource in interface ReplicaMigrationEvent

Returns:

the old owner of the migrating partition replica

getDestination

public Member getDestination()

Description copied from interface: ReplicaMigrationEvent

Returns the new owner of the migrating partition replica.

Specified by:

getDestination in interface ReplicaMigrationEvent

Returns:

the new owner of the migrating partition replica

getMigrationState

public MigrationState getMigrationState()

Description copied from interface: ReplicaMigrationEvent

Returns the progress information of the overall migration.

Specified by:

getMigrationState in interface ReplicaMigrationEvent

Returns:

migration process progress

isSuccess

public boolean isSuccess()

Description copied from interface: ReplicaMigrationEvent

Returns the result of the migration: completed or failed.

Specified by:

isSuccess in interface ReplicaMigrationEvent

Returns:

true if the migration completed successfully, false otherwise

getElapsedTime

public long getElapsedTime()

Description copied from interface: ReplicaMigrationEvent

Returns the elapsed the time of this migration in milliseconds.

Specified by:

getElapsedTime in interface ReplicaMigrationEvent

Returns:

elapsed time in milliseconds.

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

toString

public String toString()

Overrides:

toString in class Object