(p *plan.Projection)
| 231 | return NewOrder(m.Ctx, p), nil |
| 232 | } |
| 233 | func (m *JobExecutor) WalkProjection(p *plan.Projection) (Task, error) { |
| 234 | return NewProjection(m.Ctx, p), nil |
| 235 | } |
| 236 | func (m *JobExecutor) WalkJoin(p *plan.JoinMerge) (Task, error) { |
| 237 | execTask := NewTaskParallel(m.Ctx) |
| 238 | //u.Debugf("join.Left: %#v \nright:%#v", p.Left, p.Right) |
nothing calls this directly
no test coverage detected