[BEAM-2550] This closes #3506
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/aa265e62 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/aa265e62 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/aa265e62 Branch: refs/heads/DSL_SQL Commit: aa265e62a6c807ee941b1fc9379411f736754bf5 Parents: b8fa0ad e9dc5ea Author: Tyler Akidau <[email protected]> Authored: Tue Jul 11 23:47:49 2017 -0700 Committer: Tyler Akidau <[email protected]> Committed: Tue Jul 11 23:47:49 2017 -0700 ---------------------------------------------------------------------- .../beam/dsls/sql/rel/BeamIOSourceRel.java | 5 +- .../apache/beam/dsls/sql/rel/BeamJoinRel.java | 3 - .../beam/dsls/sql/BeamSqlDslJoinTest.java | 191 +++++++++++++++++++ .../org/apache/beam/dsls/sql/TestUtils.java | 25 ++- .../rel/BeamJoinRelBoundedVsBoundedTest.java | 72 +++---- 5 files changed, 255 insertions(+), 41 deletions(-) ----------------------------------------------------------------------
