tables

Documentation

Index

• func DefaultTombstoneFactory(meta *catalog.ObjectEntry) data.Tombstone
• func LoadPersistedColumnData(ctx context.Context, rt *dbutils.Runtime, id *common.ID, def *catalog.ColDef, ...) (vec containers.Vector, err error)
• func LoadPersistedColumnDatas(ctx context.Context, schema *catalog.Schema, rt *dbutils.Runtime, ...) ([]containers.Vector, error)
• func LoadPersistedDeletes(ctx context.Context, pkName string, fs *objectio.ObjectFS, ...) (bat *containers.Batch, isPersistedByCN bool, release func(), err error)
• func LoadPersistedDeletesBySchema(ctx context.Context, pkName string, fs *objectio.ObjectFS, ...) (bat *containers.Batch, release func(), err error)
• func MakeImmuIndex(ctx context.Context, meta *catalog.ObjectEntry, bf objectio.BloomFilter, ...) (idx indexwrapper.ImmutIndex, err error)
• func ReadPersistedBlockRow(location objectio.Location) int
• type BlockDataFactory
• type BlockT
• type DataFactory
  • func NewDataFactory(rt *dbutils.Runtime, dir string) *DataFactory
  • func (factory *DataFactory) MakeObjectFactory() catalog.ObjectDataFactory
  • func (factory *DataFactory) MakeTableFactory() catalog.TableDataFactory
  • func (factory *DataFactory) MakeTombstoneFactory() catalog.TombstoneFactory
• type Node
  • func NewNode(node NodeT) *Node
  • func (n *Node) MustMNode() *memoryNode
  • func (n *Node) MustPNode() *persistedNode
• type NodeT

Functions

func DefaultTombstoneFactory

func DefaultTombstoneFactory(meta *catalog.ObjectEntry) data.Tombstone

func LoadPersistedColumnData

func LoadPersistedColumnData(
	ctx context.Context,
	rt *dbutils.Runtime,
	id *common.ID,
	def *catalog.ColDef,
	location objectio.Location,
	mp *mpool.MPool,
) (vec containers.Vector, err error)

func LoadPersistedColumnDatas

func LoadPersistedColumnDatas(
	ctx context.Context,
	schema *catalog.Schema,
	rt *dbutils.Runtime,
	id *common.ID,
	colIdxs []int,
	location objectio.Location,
	mp *mpool.MPool,
) ([]containers.Vector, error)

func LoadPersistedDeletes

func LoadPersistedDeletes(
	ctx context.Context,
	pkName string,
	fs *objectio.ObjectFS,
	location objectio.Location,
	mp *mpool.MPool,
) (bat *containers.Batch, isPersistedByCN bool, release func(), err error)

func LoadPersistedDeletesBySchema

func LoadPersistedDeletesBySchema(
	ctx context.Context,
	pkName string,
	fs *objectio.ObjectFS,
	location objectio.Location,
	isPersistedByCN bool,
	mp *mpool.MPool,
) (bat *containers.Batch, release func(), err error)

func MakeImmuIndex

func MakeImmuIndex(
	ctx context.Context,
	meta *catalog.ObjectEntry,
	bf objectio.BloomFilter,
	rt *dbutils.Runtime,
) (idx indexwrapper.ImmutIndex, err error)

func ReadPersistedBlockRow

func ReadPersistedBlockRow(location objectio.Location) int

Types

type BlockDataFactory

type BlockDataFactory = func(meta *catalog.ObjectEntry) data.Object

type BlockT

type BlockT[T common.IRef] interface {
	common.IRef
	Pin() *common.PinnedItem[T]
	GetID() *common.ID
}

type DataFactory

type DataFactory struct {
	// contains filtered or unexported fields
}

func NewDataFactory

func NewDataFactory(
	rt *dbutils.Runtime, dir string,
) *DataFactory

func (*DataFactory) MakeObjectFactory

func (factory *DataFactory) MakeObjectFactory() catalog.ObjectDataFactory

func (*DataFactory) MakeTableFactory

func (factory *DataFactory) MakeTableFactory() catalog.TableDataFactory

func (*DataFactory) MakeTombstoneFactory

func (factory *DataFactory) MakeTombstoneFactory() catalog.TombstoneFactory

type Node

type Node struct {
	NodeT
}

func NewNode

func NewNode(node NodeT) *Node

func (*Node) MustMNode

func (n *Node) MustMNode() *memoryNode

func (*Node) MustPNode

func (n *Node) MustPNode() *persistedNode

type NodeT

type NodeT interface {
	common.IRef

	IsPersisted() bool

	PrepareAppend(rows uint32) (n uint32, err error)
	ApplyAppend(
		bat *containers.Batch,
		txn txnif.AsyncTxn,
	) (from int, err error)

	GetDataWindow(
		readSchema *catalog.Schema, colIdxes []int, from, to uint32, mp *mpool.MPool,
	) (bat *containers.Batch, err error)

	GetValueByRow(readSchema *catalog.Schema, row, col int) (v any, isNull bool)
	GetRowsByKey(key any) (rows []uint32, err error)
	BatchDedup(
		ctx context.Context,
		txn txnif.TxnReader,
		isCommitting bool,
		keys containers.Vector,
		keysZM index.ZM,
		rowmask *roaring.Bitmap,
		bf objectio.BloomFilter,
	) (err error)
	ContainsKey(ctx context.Context, key any, blkID uint32) (ok bool, err error)

	Rows() (uint32, error)

	GetRowByFilter(ctx context.Context, txn txnif.TxnReader, filter *handle.Filter, mp *mpool.MPool) (bid uint16, row uint32, err error)
	CollectAppendInRange(
		start, end types.TS, withAborted bool, mp *mpool.MPool,
	) (batWithVer *containers.BatchWithVersion, err error)
}