Function BuildSqlJob

exec/executor.go:46–58

BuildSqlJob given a plan context (query statement, +context) create a JobExecutor and error if we can't.

(ctx *plan.Context)

// BuildSqlJob given a plan context (query statement, +context) create
// a JobExecutor and error if we can't.
func BuildSqlJob(ctx *plan.Context) (*JobExecutor, error) {
	job := NewExecutor(ctx, plan.NewPlanner(ctx))
	task, err := BuildSqlJobPlanned(job.Planner, job.Executor, ctx)
	if err != nil {
		return nil, err
	}
	taskRunner, ok := task.(TaskRunner)
	if !ok {
		return nil, fmt.Errorf("Expected TaskRunner but was %T", task)
	}
	job.RootTask = taskRunner
	return job, err
}

// BuildSqlJobPlanned Create Job made up of sub-tasks in DAG that is the
// plan for execution of this query/job.