You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ta...@apache.org on 2017/06/29 23:35:41 UTC
[2/2] beam git commit: [BEAM-2193] This closes #3277
[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 <ta...@apache.org>
Authored: Thu Jun 29 16:34:45 2017 -0700
Committer: Tyler Akidau <ta...@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(-)
----------------------------------------------------------------------