(p *plan.Insert)
| 157 | return root, root.Add(NewUpsert(m.Ctx, p)) |
| 158 | } |
| 159 | func (m *JobExecutor) WalkInsert(p *plan.Insert) (Task, error) { |
| 160 | root := m.NewTask(p) |
| 161 | return root, root.Add(NewInsert(m.Ctx, p)) |
| 162 | } |
| 163 | func (m *JobExecutor) WalkUpdate(p *plan.Update) (Task, error) { |
| 164 | root := m.NewTask(p) |
| 165 | return root, root.Add(NewUpdate(m.Ctx, p)) |