NewCheckpointWriter creates a CheckpointWriter.

NewParallelRunner returns a new ParallelRunner.

Register registers the HorizontalReshardingWorkflowFactory as a factory in the workflow framework.

Parallel means that the tasks will run in parallel.

Sequential means that the tasks will run sequentially.

CheckpointWriter saves the checkpoint data into topology server.

HorizontalReshardingWorkflow contains meta-information and methods to control the horizontal resharding workflow.

HorizontalReshardingWorkflowFactory is the factory to create a horizontal resharding workflow.

ParallelRunner is used to control executing tasks concurrently.

ReshardingWrangler is the interface to be used in creating mock interface for wrangler, which is used for unit test.

PhaseType is used to store the phase name in a workflow.