encode

type Encoder interface {
	// Close the encoder.
	Close()

	// Encode encodes a row of SQL values into a backend-friendly format.
	Encode(row []types.Datum, rowID int64, columnPermutation []int, offset int64) (Row, error)
}

type EncodingBuilder interface {
	// NewEncoder creates an encoder of a TiDB table.
	NewEncoder(ctx context.Context, config *EncodingConfig) (Encoder, error)
	// MakeEmptyRows creates an empty collection of encoded rows.
	MakeEmptyRows() Rows
}

type EncodingConfig struct {
	SessionOptions
	Path   string // path of data file
	Table  table.Table
	Logger log.Logger
	// UseIdentityAutoRowID controls whether to use the input auto row ID directly
	// when encoding.
	// default false, in this case we will do sharding automatically if needed.
	UseIdentityAutoRowID bool
}

type Row interface {
	// ClassifyAndAppend separates the data-like and index-like parts of the
	// encoded row, and appends these parts into the existing buffers and
	// checksums.
	ClassifyAndAppend(
		data *Rows,
		dataChecksum *verification.KVChecksum,
		indices *Rows,
		indexChecksum *verification.KVChecksum,
	)

	// Size represents the total kv size of this Row.
	Size() uint64
}

type Rows interface {
	// Clear returns a new collection with empty content. It may share the
	// capacity with the current instance. The typical usage is `x = x.Clear()`.
	Clear() Rows
}

type SessionOptions struct {
	SQLMode               mysql.SQLMode
	Timestamp             int64
	SysVars               map[string]string
	LogicalImportPrepStmt bool
	// a seed used for tableKvEncoder's auto random bits value
	AutoRandomSeed int64
	// IndexID is used by the dupeDetector. Only the key range with the specified index ID is scanned.
	IndexID int64
	// MinCommitTS is used by dupeDetector. Only records that larger than commit TS are considered.
	MinCommitTS uint64
}