This closes #3067
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/523482be Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/523482be Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/523482be Branch: refs/heads/DSL_SQL Commit: 523482be0501a7bce79087f47c7752b900178a00 Parents: 6729a02 f728fbe Author: Dan Halperin <[email protected]> Authored: Fri May 12 17:47:06 2017 -0700 Committer: Dan Halperin <[email protected]> Committed: Fri May 12 17:47:06 2017 -0700 ---------------------------------------------------------------------- .../interpreter/operator/BeamSqlPrimitive.java | 35 + .../beam/dsls/sql/rel/BeamAggregationRel.java | 40 +- .../apache/beam/dsls/sql/schema/BeamSQLRow.java | 4 + .../beam/dsls/sql/schema/BeamSqlRowCoder.java | 4 +- .../sql/transform/BeamAggregationTransform.java | 120 ---- .../transform/BeamAggregationTransforms.java | 671 +++++++++++++++++++ .../transform/BeamAggregationTransformTest.java | 436 ++++++++++++ .../schema/transform/BeamTransformBaseTest.java | 96 +++ 8 files changed, 1261 insertions(+), 145 deletions(-) ----------------------------------------------------------------------
