beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dhalp...@apache.org
Subject [2/2] beam git commit: This closes #3039
Date Wed, 10 May 2017 17:03:27 GMT
This closes #3039


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6729a027
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6729a027
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/6729a027

Branch: refs/heads/DSL_SQL
Commit: 6729a027daea04d0ad38f8a83ad1baafa465169f
Parents: 7e918a7 3c6d60f
Author: Dan Halperin <dhalperi@google.com>
Authored: Wed May 10 10:03:17 2017 -0700
Committer: Dan Halperin <dhalperi@google.com>
Committed: Wed May 10 10:03:17 2017 -0700

----------------------------------------------------------------------
 dsls/sql/pom.xml                                |   6 +-
 .../dsls/sql/interpreter/BeamSQLFnExecutor.java |  20 ++-
 .../interpreter/operator/BeamSqlPrimitive.java  |  10 ++
 .../operator/BeamSqlWindowEndExpression.java    |  42 +++++
 .../operator/BeamSqlWindowExpression.java       |  50 ++++++
 .../operator/BeamSqlWindowStartExpression.java  |  43 +++++
 .../dsls/sql/planner/BeamPipelineCreator.java   |  17 +-
 .../beam/dsls/sql/planner/BeamRuleSets.java     |   4 +-
 .../beam/dsls/sql/rel/BeamAggregationRel.java   | 154 ++++++++++++++++++
 .../apache/beam/dsls/sql/rel/BeamFilterRel.java |   4 +-
 .../apache/beam/dsls/sql/rel/BeamIOSinkRel.java |   2 +-
 .../beam/dsls/sql/rel/BeamIOSourceRel.java      |   2 +-
 .../beam/dsls/sql/rel/BeamProjectRel.java       |   4 +-
 .../beam/dsls/sql/rule/BeamAggregationRule.java | 163 +++++++++++++++++++
 .../beam/dsls/sql/schema/BeamSQLRecordType.java |   5 +
 .../apache/beam/dsls/sql/schema/BeamSQLRow.java |  64 +++++++-
 .../beam/dsls/sql/schema/BeamSqlRowCoder.java   |  21 ++-
 .../sql/transform/BeamAggregationTransform.java | 120 ++++++++++++++
 .../dsls/sql/transform/BeamSQLProjectFn.java    |   8 +-
 .../beam/dsls/sql/planner/BasePlanner.java      |  61 ++++---
 .../sql/planner/BeamGroupByExplainTest.java     |  93 +++++++++++
 .../sql/planner/BeamGroupByPipelineTest.java    |  94 +++++++++++
 .../sql/planner/BeamInvalidGroupByTest.java     |  44 +++++
 .../BeamPlannerAggregationSubmitTest.java       | 136 ++++++++++++++++
 .../sql/planner/BeamPlannerExplainTest.java     |   6 +-
 .../dsls/sql/planner/BeamPlannerSubmitTest.java |  12 +-
 .../dsls/sql/planner/MockedBeamSQLTable.java    |  38 ++---
 27 files changed, 1137 insertions(+), 86 deletions(-)
----------------------------------------------------------------------



Mime
View raw message