moengine

func AppendFixedValue[T any](vec *vector.Vector, v any)

func AppendValue(vec *vector.Vector, v any)

func ApplyDeleteToVector(vec *vector.Vector, deletes *roaring.Bitmap) *vector.Vector

func ApplyUpdateToVector(vec *vector.Vector, mask *roaring.Bitmap, vals map[uint32]any) *vector.Vector

func BatchWindow(bat *batch.Batch, start, end int) *batch.Batch

func CopyToMoVector(vec containers.Vector) *vector.Vector

func CopyToMoVectors(vecs []containers.Vector) []*vector.Vector

func DefsToSchema(name string, defs []engine.TableDef) (schema *catalog.Schema, err error)

func ForEachValue(col *vector.Vector, reversed bool, op func(v any, row uint32) error) (err error)

func GenericUpdateFixedValue[T any](vec *vector.Vector, row uint32, v any)

func GetValue(col *vector.Vector, row uint32) any

func MOToVector(v *vector.Vector, nullable bool) containers.Vector

func MOToVectorTmp(v *vector.Vector, nullable bool) containers.Vector

func MOToVectors(movecs []*vector.Vector, nullables []bool) []containers.Vector

func MockVec(typ types.Type, rows int, offset int) *vector.Vector

func NewEngine(impl *db.DB) *txnEngine

func SchemaToDefs(schema *catalog.Schema) (defs []engine.TableDef, err error)

func SplitBatch(bat *batch.Batch, cnt int) []*batch.Batch

func UpdateOffsets(data *types.Bytes, start, end int)

func UpdateValue(col *vector.Vector, row uint32, val any)

func VectorsToMO(vec containers.Vector) *vector.Vector