Method WalkPlanTask

exec/executor.go:286–307

(p plan.Task)

	return root, m.WalkChildren(p, root)
}
func (m *JobExecutor) WalkPlanTask(p plan.Task) (Task, error) {
	//u.Debugf("WalkPlanTask: %p  %T", p, p)
	switch p := p.(type) {
	case *plan.Source:
		return m.Executor.WalkSource(p)
	case *plan.Where:
		return m.Executor.WalkWhere(p)
	case *plan.Having:
		return m.Executor.WalkHaving(p)
	case *plan.GroupBy:
		return m.Executor.WalkGroupBy(p)
	case *plan.Order:
		return m.Executor.WalkOrder(p)
	case *plan.Projection:
		return m.Executor.WalkProjection(p)
	case *plan.JoinMerge:
		return m.Executor.WalkJoin(p)
	case *plan.JoinKey:
		return m.Executor.WalkJoinKey(p)
	}
	panic(fmt.Sprintf("Task plan-exec Not implemented for %T", p))
}

// Other Statements