[BEAM-2446] This closes #3372
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a680904a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a680904a Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a680904a Branch: refs/heads/DSL_SQL Commit: a680904a4416be4582ffdfae77a22c2ddca6183d Parents: 887cf3a c5db277 Author: Tyler Akidau <[email protected]> Authored: Thu Jun 22 13:19:12 2017 -0700 Committer: Tyler Akidau <[email protected]> Committed: Thu Jun 22 13:19:12 2017 -0700 ---------------------------------------------------------------------- .../java/org/apache/beam/dsls/sql/BeamSql.java | 57 +++++++++++--------- .../org/apache/beam/dsls/sql/BeamSqlCli.java | 18 +++---- .../org/apache/beam/dsls/sql/BeamSqlEnv.java | 12 ++--- .../beam/dsls/sql/example/BeamSqlExample.java | 4 +- .../math/BeamSqlMathBinaryExpression.java | 1 - .../beam/dsls/sql/planner/BeamQueryPlanner.java | 7 +-- .../beam/dsls/sql/rel/BeamAggregationRel.java | 7 +-- .../apache/beam/dsls/sql/rel/BeamFilterRel.java | 8 +-- .../apache/beam/dsls/sql/rel/BeamIOSinkRel.java | 9 ++-- .../beam/dsls/sql/rel/BeamIOSourceRel.java | 7 ++- .../beam/dsls/sql/rel/BeamIntersectRel.java | 8 +-- .../apache/beam/dsls/sql/rel/BeamMinusRel.java | 8 +-- .../beam/dsls/sql/rel/BeamProjectRel.java | 7 +-- .../apache/beam/dsls/sql/rel/BeamRelNode.java | 7 +-- .../dsls/sql/rel/BeamSetOperatorRelBase.java | 10 ++-- .../apache/beam/dsls/sql/rel/BeamSortRel.java | 7 +-- .../apache/beam/dsls/sql/rel/BeamUnionRel.java | 8 +-- .../apache/beam/dsls/sql/rel/BeamValuesRel.java | 6 +-- .../beam/dsls/sql/utils/CalciteUtils.java | 1 - .../beam/dsls/sql/rel/BeamIntersectRelTest.java | 10 ++-- .../beam/dsls/sql/rel/BeamMinusRelTest.java | 10 ++-- .../sql/rel/BeamSetOperatorRelBaseTest.java | 8 +-- .../beam/dsls/sql/rel/BeamSortRelTest.java | 26 ++++----- .../beam/dsls/sql/rel/BeamUnionRelTest.java | 8 +-- .../beam/dsls/sql/rel/BeamValuesRelTest.java | 12 +++-- 25 files changed, 141 insertions(+), 125 deletions(-) ----------------------------------------------------------------------
