[BEAM-2288] This closes #3137
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/25babc99 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/25babc99 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/25babc99 Branch: refs/heads/DSL_SQL Commit: 25babc999e964775834503e25043e3a8d7b6d030 Parents: f96f9f6 7b3f7a2 Author: Jean-Baptiste Onofré <jbono...@apache.org> Authored: Wed May 17 23:13:24 2017 +0200 Committer: Jean-Baptiste Onofré <jbono...@apache.org> Committed: Wed May 17 23:13:24 2017 +0200 ---------------------------------------------------------------------- .../beam/dsls/sql/BeamSQLEnvironment.java | 142 +++++++++++++++++++ .../beam/dsls/sql/example/BeamSqlExample.java | 23 ++- .../dsls/sql/planner/BeamPipelineCreator.java | 9 +- .../beam/dsls/sql/planner/BeamQueryPlanner.java | 34 ++--- .../beam/dsls/sql/planner/BeamSqlRunner.java | 103 -------------- .../beam/dsls/sql/planner/BasePlanner.java | 9 +- .../sql/planner/BeamGroupByExplainTest.java | 14 +- .../sql/planner/BeamGroupByPipelineTest.java | 19 +-- .../sql/planner/BeamInvalidGroupByTest.java | 10 +- .../BeamPlannerAggregationSubmitTest.java | 17 ++- .../sql/planner/BeamPlannerExplainTest.java | 7 +- .../dsls/sql/planner/BeamPlannerSubmitTest.java | 11 +- .../beam/dsls/sql/rel/BeamSortRelTest.java | 40 ++++-- 13 files changed, 251 insertions(+), 187 deletions(-) ----------------------------------------------------------------------
