software.amazon.kinesis.coordinator.migration

Class MigrationClientVersion3xState

java.lang.Object

software.amazon.kinesis.coordinator.migration.AbstractMigrationClientVersionState

software.amazon.kinesis.coordinator.migration.MigrationClientVersion3xState

All Implemented Interfaces:

MigrationClientVersionState

@ThreadSafe
public class MigrationClientVersion3xState
extends AbstractMigrationClientVersionState

State for CLIENT_VERSION_3X which enables KCL to run 3.x algorithms on new KCLv3.x application or successfully upgraded application which upgraded from v2.x. This is a terminal state of the state machine and no rollbacks are supported in this state.

Field Summary

Fields inherited from class software.amazon.kinesis.coordinator.migration.AbstractMigrationClientVersionState

coordinatorStateDAO, curentMigrationState, entered, left

Constructor Summary

Constructors

Constructor and Description
MigrationClientVersion3xState(MigrationStateMachine stateMachine, DynamicMigrationComponentsInitializer initializer, CoordinatorStateDAO coordinatorStateDAO, MigrationState migrationState, String workerIdentifier)

Method Summary

Modifier and Type	Method and Description
ClientVersion	clientVersion() The associated clientVersion this state corresponds to
protected void	doEnter(ClientVersion fromClientVersion) State-specific enter logic.
void	leave() Invoked after the transition to another state has occurred to allow printing any helpful logs or performing cleanup.
String	toString()

Methods inherited from class software.amazon.kinesis.coordinator.migration.AbstractMigrationClientVersionState

enter

Methods inherited from class java.lang.Object

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

Constructor Detail

MigrationClientVersion3xState

public MigrationClientVersion3xState(MigrationStateMachine stateMachine,
                                     DynamicMigrationComponentsInitializer initializer,
                                     CoordinatorStateDAO coordinatorStateDAO,
                                     MigrationState migrationState,
                                     String workerIdentifier)

Method Detail

clientVersion

public ClientVersion clientVersion()

Description copied from interface: MigrationClientVersionState

The associated clientVersion this state corresponds to

Returns:

ClientVersion that this state implements the logic for.

doEnter

protected void doEnter(ClientVersion fromClientVersion)
                throws DependencyException

Description copied from class: AbstractMigrationClientVersionState

State-specific enter logic. Called after DDB state has been verified/updated.

Specified by:

doEnter in class AbstractMigrationClientVersionState

Parameters:

fromClientVersion - the client version of the previous state

Throws:

DependencyException - if state-specific initialization fails

leave

public void leave()

Description copied from interface: MigrationClientVersionState

Invoked after the transition to another state has occurred to allow printing any helpful logs or performing cleanup.

toString

public String toString()

Overrides:

toString in class Object