tables

package
v1.0.2 Latest Latest
Warning

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

Go to latest
Published: Dec 21, 2023 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func LoadPersistedColumnData added in v0.7.0

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

func LoadPersistedDeletes added in v0.7.0

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

	location objectio.Location) (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) MakeSegmentFactory

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

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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