Package mock is a generated GoMock package.

GetTaskImportedRows gets the number of imported rows of a job.

NewImportExecutor creates a new import task executor.

NewImportScheduler creates a new import scheduler.

NewPostProcessStepExecutor creates a new post process step executor.

SubmitStandaloneTask submits a task to the distribute framework that only runs on the current node.

SubmitTask submits a task to the distribute framework that runs on all managed nodes.

TaskKey returns the task key for a job.

NewTaskRegisterWithTTL is the ctor for TaskRegister.

Checksum records the checksum information.

Chunk records the chunk information.

ImportCleanUpS3 implements scheduler.CleanUpRoutine.

ImportSchedulerExt is an extension of ImportScheduler, exported for test.

ImportSpec is the specification of an import pipeline.

ImportStepMeta is the meta of import step.

LogicalPlan represents a logical plan for import into.

MergeSortSpec is the specification of a merge-sort pipeline.

MergeSortStepMeta is the meta of merge sort step.

PostProcessSpec is the specification of a post process pipeline.

PostProcessStepMeta is the meta of post process step.

Result records the metrics information.

SharedVars is the shared variables of all minimal tasks in a subtask.

TaskMeta is the task of IMPORT INTO.

WriteIngestSpec is the specification of a write-ingest pipeline.

WriteIngestStepMeta is the meta of write and ingest step.

MiniTaskExecutor is the interface for a minimal task executor.