writer

type BaseTask struct {
	*plugin.BaseTask
}

type Job interface {
	plugin.Job

	// According to Job, the original task is divided into as many tasks as possible, which are mainly passed to each task in the form of configuration files.
	Split(ctx context.Context, number int) ([]*config.JSON, error)
}

type Task interface {
	plugin.Task

	// Start reading records from the receiver and write them
	StartWrite(ctx context.Context, receiver plugin.RecordReceiver) error
	// SupportFailOver: whether fault tolerance is supported, i.e., whether to retry after a failed write
	SupportFailOver() bool
}