equal
deleted
inserted
replaced
305 rewriter.rewrite(union, plan.args) |
305 rewriter.rewrite(union, plan.args) |
306 self.rqlhelper.annotate(union) |
306 self.rqlhelper.annotate(union) |
307 return self.build_select_plan(plan, union) |
307 return self.build_select_plan(plan, union) |
308 |
308 |
309 |
309 |
|
310 def prepare_plan(plan, schema, rqlhelper): |
|
311 """Add steps to a plan to prepare it for execution""" |
|
312 return SSPlanner(schema, rqlhelper).build_plan(plan) |
|
313 |
|
314 |
310 # execution steps and helper functions ######################################## |
315 # execution steps and helper functions ######################################## |
311 |
316 |
312 class Step(object): |
317 class Step(object): |
313 """base abstract class for execution step""" |
318 """base abstract class for execution step""" |
314 def __init__(self, plan): |
319 def __init__(self, plan): |