table_edit_accumulator.go at e87a82628efef984bef259dd02fe53a3c6ddffa7 - STRLCPY/dolt

ROOT /

go /

table /

table_edit_accumulator.go

486 lines | ISO-8859-1 | 16 KB

Blame Outline

Outline

k : types.Tuple

v : types.Tuple

TableEditAccumulator

Delete(keyHash hash.Hash, key types.Tuple) : error

Insert(keyHash hash.Hash, key types.Tuple, val types.Tuple) : error

Get(ctx context.Context, keyHash hash.Hash, key types.Tuple) : (*doltKVP, bool, error)

HasPartial(ctx context.Context, idxSch schema.Schema, partialKeyHash hash.Hash, partialKey types.Tuple) : ([]hashedTuple, error)

Commit(ctx context.Context, nbf *types.NomsBinFormat) : error

Rollback(ctx context.Context) : error

MaterializeEdits(ctx context.Context, nbf *types.NomsBinFormat) : (m types.Map, err error)

flushThreshold : int64

inMemModifications

adds : map[hash.Hash]*doltKVP

deletes : map[hash.Hash]types.Tuple

newInMemModifications() : *inMemModifications

NewTableEA(ctx context.Context, rowData types.Map) : TableEditAccumulator

NewIndexEA(ctx context.Context, rowData types.Map) : IndexEditAccumulator

directory : string

vrw : types.ValueReadWriter

NewDbEaFactory(directory string, vrw types.ValueReadWriter) : DbEaFactory

*inMemModifications

MergeIn(other *inMemModifications)

Get(keyHash hash.Hash) : (kvp *doltKVP, added, deleted bool)

*tableEditAccumulatorImpl

Get(ctx context.Context, keyHash hash.Hash, key types.Tuple) : (*doltKVP, bool, error)

HasPartial(ctx context.Context, idxSch schema.Schema, partialKeyHash hash.Hash, partialKey types.Tuple) : ([]hashedTuple, error)

flushUncommitted()

Delete(keyHash hash.Hash, key types.Tuple) : error

Insert(keyHash hash.Hash, key types.Tuple, val types.Tuple) : error

Commit(ctx context.Context, nbf *types.NomsBinFormat) : error

Rollback(ctx context.Context) : error

MaterializeEdits(ctx context.Context, nbf *types.NomsBinFormat) : (m types.Map, err error)

NewTableEA(ctx context.Context, rowData types.Map) : TableEditAccumulator

NewIndexEA(ctx context.Context, rowData types.Map) : IndexEditAccumulator

Please wait...

Page is in error, reload to recover