Method Run

cmd/super/dev/vector/search/command.go:47–84

(args []string)

}

func (c *Command) Run(args []string) error {
	ctx, cleanup, err := c.Init(&c.outputFlags)
	if err != nil {
		return err
	}
	defer cleanup()
	if len(args) != 1 {
		return errors.New("usage: filter expression")
	}
	db, err := c.dbFlags.Open(ctx)
	if err != nil {
		return err
	}
	root := db.Root()
	if root == nil {
		return errors.New("remote databases not supported")
	}
	head, err := c.poolFlags.HEAD()
	if err != nil {
		return err
	}
	text := args[0]
	sctx := super.NewContext()
	rctx := runtime.NewContext(ctx, sctx)
	puller, err := compiler.VectorFilterCompile(rctx, text, exec.NewEnvironment(nil, root), head)
	if err != nil {
		return err
	}
	writer, err := c.outputFlags.Open(ctx, storage.NewLocalEngine())
	if err != nil {
		return err
	}
	if err := vio.Copy(writer, sbuf.NewDematerializer(sctx, puller)); err != nil {
		writer.Close()
		return err
	}
	return writer.Close()
}