tables

package

v1.2.2-yidao Latest Latest Go to latest Published: Jun 26, 2025 License: Apache-2.0 Imports: 29 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/matrixorigin/matrixone

Links

Open Source Insights

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
type Node
- func NewNode(node NodeT) *Node
- func (n *Node) MustMNode() *memoryNode
- func (n *Node) MustPNode() *persistedNode
type NodeT

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
jobs
txnentries
updates

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