[BEAM-2325] This closes #3183
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/315f266a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/315f266a Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/315f266a Branch: refs/heads/DSL_SQL Commit: 315f266a6e24cd851a98cba320635c9673ba3dac Parents: c017159 81d699e Author: Jean-Baptiste Onofré <[email protected]> Authored: Tue Jun 13 14:40:56 2017 +0200 Committer: Jean-Baptiste Onofré <[email protected]> Committed: Tue Jun 13 14:40:56 2017 +0200 ---------------------------------------------------------------------- .../beam/dsls/sql/planner/BeamRuleSets.java | 7 +- .../beam/dsls/sql/rel/BeamAggregationRel.java | 15 ++- .../beam/dsls/sql/rel/BeamIntersectRel.java | 58 +++++++++ .../apache/beam/dsls/sql/rel/BeamMinusRel.java | 56 +++++++++ .../dsls/sql/rel/BeamSetOperatorRelBase.java | 99 +++++++++++++++ .../apache/beam/dsls/sql/rel/BeamUnionRel.java | 88 +++++++++++++ .../beam/dsls/sql/rule/BeamIntersectRule.java | 51 ++++++++ .../beam/dsls/sql/rule/BeamMinusRule.java | 51 ++++++++ .../beam/dsls/sql/rule/BeamUnionRule.java | 50 ++++++++ .../apache/beam/dsls/sql/schema/BeamSqlRow.java | 3 +- .../transform/BeamSetOperatorsTransforms.java | 113 +++++++++++++++++ .../dsls/sql/planner/MockedBeamSqlTable.java | 6 +- .../beam/dsls/sql/rel/BeamIntersectRelTest.java | 111 +++++++++++++++++ .../beam/dsls/sql/rel/BeamMinusRelTest.java | 110 +++++++++++++++++ .../sql/rel/BeamSetOperatorRelBaseTest.java | 122 +++++++++++++++++++ .../beam/dsls/sql/rel/BeamUnionRelTest.java | 99 +++++++++++++++ .../org/apache/beam/dsls/sql/rel/CheckSize.java | 41 +++++++ 17 files changed, 1069 insertions(+), 11 deletions(-) ----------------------------------------------------------------------
