tables

Documentation

Index

• 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, err error)
• func MakeImmuIndex(ctx context.Context, meta *catalog.BlockEntry, bf objectio.BloomFilter, ...) (idx indexwrapper.ImmutIndex, err error)
• func ReadPersistedBlockRow(location objectio.Location) int
• type AblkTempFilter
  • func (f *AblkTempFilter) Add(id types.Blockid)
  • func (f *AblkTempFilter) Check(id types.Blockid) (skip bool)
• type BlockT
• type DataFactory
  • func NewDataFactory(rt *dbutils.Runtime, dir string) *DataFactory
  • func (factory *DataFactory) MakeBlockFactory() catalog.BlockDataFactory
  • func (factory *DataFactory) MakeSegmentFactory() catalog.SegmentDataFactory
  • func (factory *DataFactory) MakeTableFactory() catalog.TableDataFactory
• type Node
  • func NewNode(node NodeT) *Node
  • func (n *Node) MustMNode() *memoryNode
  • func (n *Node) MustPNode() *persistedNode
• type NodeT

Functions

func LoadPersistedColumnData

func LoadPersistedColumnData(
	ctx context.Context,
	rt *dbutils.Runtime,
	id *common.ID,
	def *catalog.ColDef,
	location objectio.Location,
) (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,
) ([]containers.Vector, error)

func LoadPersistedDeletes

func LoadPersistedDeletes(
	ctx context.Context,
	pkName string,
	fs *objectio.ObjectFS,

	location objectio.Location) (bat *containers.Batch, isPersistedByCN bool, err error)

func MakeImmuIndex

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

func ReadPersistedBlockRow

func ReadPersistedBlockRow(location objectio.Location) int

Types

type AblkTempFilter

type AblkTempFilter struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

var AblkTempF *AblkTempFilter

func (*AblkTempFilter) Add

func (f *AblkTempFilter) Add(id types.Blockid)

func (*AblkTempFilter) Check

func (f *AblkTempFilter) Check(id types.Blockid) (skip bool)

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) MakeBlockFactory

func (factory *DataFactory) MakeBlockFactory() catalog.BlockDataFactory

func (*DataFactory) MakeSegmentFactory

func (factory *DataFactory) MakeSegmentFactory() catalog.SegmentDataFactory

func (*DataFactory) MakeTableFactory

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

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,
	) (bat *containers.Batch, err error)
	GetColumnDataWindow(
		readSchema *catalog.Schema,
		from uint32,
		to uint32,
		col int,
	) (vec containers.Vector, 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) (ok bool, err error)

	Rows() uint32

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