tables

package
v1.2.3-hotfix-20241010 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 11, 2024 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DefaultTombstoneFactory added in v1.2.1

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

func LoadPersistedColumnData added in v0.7.0

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 added in v0.8.0

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 added in v0.7.0

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 added in v1.2.0

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 added in v0.8.0

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

func ReadPersistedBlockRow added in v0.7.0

func ReadPersistedBlockRow(location objectio.Location) int

Types

type BlockDataFactory added in v1.2.0

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

type BlockT added in v0.7.0

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 added in v1.2.0

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

func (*DataFactory) MakeTableFactory

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

func (*DataFactory) MakeTombstoneFactory added in v1.2.0

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

type Node added in v0.7.0

type Node struct {
	NodeT
}

func NewNode added in v0.7.0

func NewNode(node NodeT) *Node

func (*Node) MustMNode added in v0.7.0

func (n *Node) MustMNode() *memoryNode

func (*Node) MustPNode added in v0.7.0

func (n *Node) MustPNode() *persistedNode

type NodeT added in v0.7.0

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL