tables

package

v1.1.3 Latest Latest Go to latest Published: Apr 15, 2024 License: Apache-2.0 Imports: 28 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/matrixorigin/matrixone

Links

Open Source Insights

Documentation ¶

Index ¶

func BuildObjectCompactionTaskFactory(meta *catalog.ObjectEntry, rt *dbutils.Runtime) (factory tasks.TxnTaskFactory, taskType tasks.TaskType, scopes []common.ID, ...)
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) MakeTableFactory() catalog.TableDataFactory
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 BuildObjectCompactionTaskFactory ¶ added in v1.1.0

func BuildObjectCompactionTaskFactory(meta *catalog.ObjectEntry, rt *dbutils.Runtime) (
	factory tasks.TxnTaskFactory, taskType tasks.TaskType, scopes []common.ID, err error,
)

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, err error)

func MakeImmuIndex ¶ added in v0.8.0

func MakeImmuIndex(
	ctx context.Context,
	meta *catalog.BlockEntry,
	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 AblkTempFilter ¶ added in v1.0.1

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

var AblkTempF *AblkTempFilter

func (*AblkTempFilter) Add ¶ added in v1.0.1

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

func (*AblkTempFilter) Check ¶ added in v1.0.1

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

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

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

func (*DataFactory) MakeTableFactory ¶

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

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)
	GetColumnDataWindow(
		readSchema *catalog.Schema,
		from uint32,
		to uint32,
		col int,
		mp *mpool.MPool,
	) (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, mp *mpool.MPool) (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