Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidParam = errors.New("tae: invalid param") ErrInvalidName = errors.New("tae: invalid name") )
Functions ¶
This section is empty.
Types ¶
type Block ¶
type Block interface {
Base
Sync() error
// IsAppendable() bool
WriteTS(ts uint64) error
ReadTS() (uint64, error)
WriteRows(rows uint32) error
ReadRows() uint32
// OpenDeletesFile() common.IRWFile
WriteDeletes(buf []byte) error
ReadDeletes(buf []byte) error
GetDeletesFileStat() common.FileInfo
LoadDeletes() (*roaring.Bitmap, error)
LoadUpdates() (map[uint16]*roaring.Bitmap, map[uint16]map[uint32]any)
LoadIndexMeta() (any, error)
WriteIndexMeta(buf []byte) (err error)
OpenColumn(colIdx int) (ColumnBlock, error)
// TODO: Remove later
WriteSnapshot(bat *containers.Batch, ts uint64, masks map[uint16]*roaring.Bitmap,
vals map[uint16]map[uint32]any, deletes *roaring.Bitmap) error
WriteBatch(bat *containers.Batch, ts uint64) error
LoadBatch([]types.Type, []string, []bool, *containers.Options) (bat *containers.Batch, err error)
WriteColumnVec(ts uint64, colIdx int, vec containers.Vector) error
Destroy() error
}
type ColumnBlock ¶
type ColumnBlock interface {
io.Closer
WriteTS(ts uint64) error
WriteData(buf []byte) error
WriteIndex(idx int, buf []byte) error
WriteUpdates(buf []byte) error
ReadTS() uint64
ReadData(buf []byte) error
ReadIndex(idx int, buf []byte) error
ReadUpdates(buf []byte) error
GetDataFileStat() common.FileInfo
OpenUpdateFile() (common.IRWFile, error)
OpenIndexFile(idx int) (common.IRWFile, error)
OpenDataFile() (common.IRWFile, error)
}
Click to show internal directories.
Click to hide internal directories.