Method NewQuery

compiler/compiler.go:38–43

(rctx *runtime.Context, ast *parser.AST, readers []sio.Reader, parallelism int)

}

func (c *compiler) NewQuery(rctx *runtime.Context, ast *parser.AST, readers []sio.Reader, parallelism int) (runtime.Query, error) {
	if parallelism == 0 {
		parallelism = Parallelism
	}
	return CompileWithAST(rctx, ast, c.env, true, parallelism, readers)
}

func (l *compiler) NewDeleteQuery(rctx *runtime.Context, ast *parser.AST, head *dbid.Commitish) (runtime.DeleteQuery, error) {
	if err := ast.ConvertToDeleteWhere(head.Pool, head.Branch); err != nil {