Method WalkSelect

exec/executor.go:151–154

DML WalkSelect create dag of plan Select.

(p *plan.Select)

// WalkSelect create dag of plan Select.
func (m *JobExecutor) WalkSelect(p *plan.Select) (Task, error) {
	root := m.NewTask(p)
	return root, m.WalkChildren(p, root)
}
func (m *JobExecutor) WalkUpsert(p *plan.Upsert) (Task, error) {
	root := m.NewTask(p)
	return root, root.Add(NewUpsert(m.Ctx, p))