file

type BaseConfig struct {
	BatchSize    int            `json:"batchSize"`    // Single Batch Write Size - The number of records to be written in a single batch.
	BatchTimeout time2.Duration `json:"batchTimeout"` // Single Batch Write Timeout - The maximum time allowed for a single batch write operation.
}

type Config interface {
	GetBatchSize() int              // Single Batch Write Size - The number of records to be written in a single batch.
	GetBatchTimeout() time.Duration // Single Batch Write Timeout - The maximum time allowed for a single batch write operation.
}

type Job struct {
	*plugin.BaseJob
}

type Task struct {
	*writer.BaseTask
	// contains filtered or unexported fields
}