Function NewCompilerWithEnv

compiler/compiler.go:34–36

(env *exec.Environment)

}

func NewCompilerWithEnv(env *exec.Environment) runtime.Compiler {
	return &compiler{env}
}

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