[BEAM-2193] This closes #3277
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2096da25 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2096da25 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2096da25 Branch: refs/heads/DSL_SQL Commit: 2096da25e85d97ab52850453c2130ff706d7bcdf Parents: ab4b118 928cec5 Author: Tyler Akidau <taki...@apache.org> Authored: Thu Jun 29 16:34:45 2017 -0700 Committer: Tyler Akidau <taki...@apache.org> Committed: Thu Jun 29 16:34:45 2017 -0700 ---------------------------------------------------------------------- dsls/pom.xml | 2 +- dsls/sql/pom.xml | 16 +- .../beam/dsls/sql/planner/BeamRuleSets.java | 6 +- .../beam/dsls/sql/rel/BeamAggregationRel.java | 19 +- .../apache/beam/dsls/sql/rel/BeamJoinRel.java | 305 +++++++++++++++++++ .../apache/beam/dsls/sql/rule/BeamJoinRule.java | 53 ++++ .../beam/dsls/sql/schema/BeamSqlRecordType.java | 2 +- .../apache/beam/dsls/sql/schema/BeamSqlRow.java | 2 +- .../beam/dsls/sql/schema/BeamSqlRowCoder.java | 3 - .../dsls/sql/transform/BeamJoinTransforms.java | 166 ++++++++++ .../org/apache/beam/dsls/sql/TestUtils.java | 125 ++++++++ .../dsls/sql/planner/MockedBeamSqlTable.java | 5 +- .../beam/dsls/sql/planner/MockedTable.java | 33 ++ .../dsls/sql/planner/MockedUnboundedTable.java | 120 ++++++++ .../rel/BeamJoinRelBoundedVsBoundedTest.java | 195 ++++++++++++ .../rel/BeamJoinRelUnboundedVsBoundedTest.java | 242 +++++++++++++++ .../BeamJoinRelUnboundedVsUnboundedTest.java | 219 +++++++++++++ .../dsls/sql/schema/BeamSqlRowCoderTest.java | 2 +- 18 files changed, 1486 insertions(+), 29 deletions(-) ----------------------------------------------------------------------