batch

package

v0.4.0 Latest Latest Go to latest Published: May 5, 2022 License: Apache-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

View Source

var (
	BatNotFoundErr      = errors.New("not found error")
	BatAlreadyClosedErr = errors.New("already closed error")
)

This section is empty.

type Batch struct {
	sync.RWMutex
	AttrsMap   map[int]int
	Attrs      []int
	Vecs       []vector.IVector
	ClosedMask *roaring.Bitmap
}

func (bat *Batch) Close() error

func (bat *Batch) CloseVector(attr int) error

func (bat *Batch) GetAttrs() []int

func (bat *Batch) GetReaderByAttr(attr int) (dbi.IVectorReader, error)

func (bat *Batch) GetVectorByAttr(attr int) (vector.IVector, error)

func (bat *Batch) IsReadonly() bool

func (bat *Batch) IsVectorClosed(attr int) (bool, error)

func (bat *Batch) Length() int

type IBatch interface {
	dbi.IBatchReader
	GetVectorByAttr(attrId int) (vector.IVector, error)
}

func NewBatch(attrs []int, vecs []vector.IVector) (IBatch, error)