blockio

func BlockDataRead(
	ctx context.Context,
	info *objectio.BlockInfo,
	ds engine.DataSource,
	columns []uint16,
	colTypes []types.Type,
	phyAddrColumnPos int,
	ts timestamp.Timestamp,
	filterSeqnums []uint16,
	filterColTypes []types.Type,
	filter objectio.BlockReadFilter,
	orderByLimit *objectio.IndexReaderTopOp,
	policy fileservice.Policy,
	tableName string,
	bat *batch.Batch,
	cacheVectors containers.Vectors,
	mp *mpool.MPool,
	fs fileservice.FileService,
) error

func BlockDataReadBackup(
	ctx context.Context,
	info *objectio.BlockInfo,
	ds engine.DataSource,
	idxes []uint16,
	ts types.TS,
	fs fileservice.FileService,
) (loaded *batch.Batch, sortKey uint16, err error)

func BlockDataReadInner(
	ctx context.Context,
	info *objectio.BlockInfo,
	ds engine.DataSource,
	columns []uint16,
	colTypes []types.Type,
	phyAddrColumnPos int,
	ts types.TS,
	selectRows []int64,
	orderByLimit *objectio.IndexReaderTopOp,
	policy fileservice.Policy,
	outputBat *batch.Batch,
	cacheVectors containers.Vectors,
	mp *mpool.MPool,
	fs fileservice.FileService,
) (err error)

func BlockDataReadNoCopy(
	ctx context.Context,
	info *objectio.BlockInfo,
	ds engine.DataSource,
	columns []uint16,
	colTypes []types.Type,
	ts types.TS,
	policy fileservice.Policy,
	mp *mpool.MPool,
	fs fileservice.FileService,
) (*batch.Batch, *nulls.Bitmap, func(), error)

func CopyBlockData(
	ctx context.Context,
	location objectio.Location,
	deletes []int64,
	seqnums []uint16,
	colTypes []types.Type,
	outputBat *batch.Batch,
	fs fileservice.FileService,
	mp *mpool.MPool,
) (err error)

func HandleOrderByLimitOnIVFFlatIndex(
	ctx context.Context,
	selectRows []int64,
	vecCol *vector.Vector,
	orderByLimit *objectio.IndexReaderTopOp,
) ([]int64, []float64, error)

func ReadDataByFilter(
	ctx context.Context,
	tableName string,
	info *objectio.BlockInfo,
	ds engine.DataSource,
	columns []uint16,
	colTypes []types.Type,
	ts types.TS,
	searchFunc objectio.ReadFilterSearchFuncType,
	cacheVectors containers.Vectors,
	mp *mpool.MPool,
	fs fileservice.FileService,
) (sels []int64, err error)