com.hazelcast.internal.partition

Class MigrationStateImpl

java.lang.Object

com.hazelcast.internal.partition.MigrationStateImpl

All Implemented Interfaces:

DataSerializable, IdentifiedDataSerializable, MigrationState

public class MigrationStateImpl
extends Object
implements MigrationState, IdentifiedDataSerializable

Summary of the migration state. Main implementation of MigrationState.

Constructor Summary

Constructors

Constructor and Description
MigrationStateImpl()
MigrationStateImpl(long startTime, int plannedMigrations, int completedMigrations, long totalElapsedTime)

Method Summary

Modifier and Type	Method and Description
int	getClassId() Returns type identifier for this class.
int	getCompletedMigrations() Returns the number of completed migrations in the migration plan.
int	getFactoryId() Returns DataSerializableFactory factory ID for this class.
int	getPlannedMigrations() Returns the number of planned migrations in the migration plan.
int	getRemainingMigrations() Returns the number of remaining migrations in the migration plan.
long	getStartTime() Returns the start time of the migration in milliseconds since the epoch.
long	getTotalElapsedTime() Returns the total elapsed time of completed migrations in milliseconds.
MigrationStateImpl	onComplete(int migrations, long elapsed)
MigrationStateImpl	onComplete(long elapsed)
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

MigrationStateImpl

public MigrationStateImpl()

MigrationStateImpl

public MigrationStateImpl(long startTime,
                          int plannedMigrations,
                          int completedMigrations,
                          long totalElapsedTime)

Method Detail

getStartTime

public long getStartTime()

Description copied from interface: MigrationState

Returns the start time of the migration in milliseconds since the epoch.

Specified by:

getStartTime in interface MigrationState

Returns:

start time of the migration process

getPlannedMigrations

public int getPlannedMigrations()

Description copied from interface: MigrationState

Returns the number of planned migrations in the migration plan.

Specified by:

getPlannedMigrations in interface MigrationState

Returns:

number of planned migrations

getCompletedMigrations

public int getCompletedMigrations()

Description copied from interface: MigrationState

Returns the number of completed migrations in the migration plan.

Specified by:

getCompletedMigrations in interface MigrationState

Returns:

number of completed migrations

getRemainingMigrations

public int getRemainingMigrations()

Description copied from interface: MigrationState

Returns the number of remaining migrations in the migration plan.

Specified by:

getRemainingMigrations in interface MigrationState

Returns:

number of remaining migrations

getTotalElapsedTime

public long getTotalElapsedTime()

Description copied from interface: MigrationState

Returns the total elapsed time of completed migrations in milliseconds.

Specified by:

getTotalElapsedTime in interface MigrationState

Returns:

total elapsed time in milliseconds

onComplete

public MigrationStateImpl onComplete(long elapsed)

onComplete

public MigrationStateImpl onComplete(int migrations,
                                     long elapsed)

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