Function NewExecutor

exec/executor.go:36–42

NewExecutor creates a new Job Executor.

(ctx *plan.Context, planner plan.Planner)

// NewExecutor creates a new Job Executor.
func NewExecutor(ctx *plan.Context, planner plan.Planner) *JobExecutor {
	e := &JobExecutor{}
	e.Executor = e
	e.Planner = planner
	e.Ctx = ctx
	return e
}

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