tables

type BlockT[T common.IRef] interface {
	common.IRef
	Pin() *common.PinnedItem[T]
	GetID() *common.ID
}

type DataFactory struct {
	AppendBufMgr base.INodeManager
	Scheduler    tasks.TaskScheduler

	Fs *objectio.ObjectFS
	// contains filtered or unexported fields
}

type Node struct {
	NodeT
}

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(from, to uint32) (bat *containers.Batch, err error)
	GetColumnDataWindow(
		from uint32,
		to uint32,
		colIdx int,
		buffer *bytes.Buffer,
	) (vec containers.Vector, err error)

	GetValueByRow(row, col int) (v any)
	GetRowsByKey(key any) (rows []uint32, err error)
	BatchDedup(
		keys containers.Vector,
		skipFn func(row uint32) error,
	) (sels *roaring.Bitmap, err error)
	ContainsKey(key any) (ok bool, err error)

	Rows() uint32
}