tables

func HybridScanByBlock ¶

func HybridScanByBlock(
	ctx context.Context,
	tableEntry *catalog.TableEntry,
	txn txnif.TxnReader,
	bat **containers.Batch,
	readSchema *catalog.Schema,
	colIdxs []int,
	blkID *objectio.Blockid,
	mp *mpool.MPool,
) error

func LoadPersistedColumnData ¶ added in v0.7.0

func LoadPersistedColumnData(
	ctx context.Context,
	schema *catalog.Schema,
	rt *dbutils.Runtime,
	id *common.ID,
	colIdxs []int,
	location objectio.Location,
	mp *mpool.MPool,
	tsForAppendable *types.TS,
	needCopy bool,
) ([]containers.Vector, *nulls.Nulls, func(), 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 PreparePhyAddrData ¶

func PreparePhyAddrData(
	id *objectio.Blockid, startRow, length uint32, pool *containers.VectorPool,
) (col containers.Vector, err error)

func RangeScanInMemoryByObject ¶

func RangeScanInMemoryByObject(
	ctx context.Context,
	objEntry *catalog.ObjectEntry,
	batches map[uint32]*containers.BatchWithVersion,
	start, end types.TS,
	mp *mpool.MPool,
) (err error)

func ReadMergeSettingsBatch ¶

func ReadMergeSettingsBatch(ctx context.Context, entry *catalog.TableEntry, readTxn txnif.AsyncTxn) *containers.Batch

func ReadSysTableBatch ¶

func ReadSysTableBatch(ctx context.Context, entry *catalog.TableEntry, readTxn txnif.AsyncTxn) *containers.Batch

TODO: ensure bat does not exceed the 1G limit

func TombstoneRangeScanByObject ¶

func TombstoneRangeScanByObject(
	ctx context.Context,
	tableEntry *catalog.TableEntry,
	objectID objectio.ObjectId,
	start, end types.TS,
	mp *mpool.MPool,
	vpool *containers.VectorPool,
) (bat *containers.Batch, err error)

TombstoneRangeScanByObject scans the an object's tombstones committed in the range [start, end] and returns a batch of data.

Since the returned batch must have accruate ts for each row, we need collect the data from appendable objects.

Targets: 1. CNCreated entries where start <= CreatedAt <= end 2. Appendable entries where x <= CreatedAt <= end, where x is the first appendable entry with CreatedAt < start

func WithScanNoCopy ¶

func WithScanNoCopy(ctx context.Context) context.Context

WithScanNoCopy signals the scan chain to use zero-copy mode (needCopy=false). Vectors will wrap fileservice buffers directly; the caller must hold the returned DataRelease on the batch until the data is fully consumed.