You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by am...@apache.org on 2020/07/15 00:59:12 UTC

[beam] branch master updated (613edd3 -> b80dc54)

This is an automated email from the ASF dual-hosted git repository.

amaliujia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from 613edd3  Make tracking/cleanup of cache and in-environment states per pipeline (#12249)
     add b80dc54  [BEAM-9198] BeamSQL aggregation analytics functionality (#11975)

No new revisions were added by this update.

Summary of changes:
 .../apache/beam/sdk/schemas/transforms/Group.java  |   2 +-
 .../extensions/sql/impl/planner/BeamRuleSets.java  |   5 +
 .../sdk/extensions/sql/impl/rel/BeamSortRel.java   |   2 +-
 .../sdk/extensions/sql/impl/rel/BeamWindowRel.java | 417 +++++++++++++++++++++
 .../sdk/extensions/sql/impl/rule/BeamCalcRule.java |  23 +-
 .../{BeamValuesRule.java => BeamWindowRule.java}   |  32 +-
 .../transform/BeamBuiltinAnalyticFunctions.java    |  45 +++
 .../transform/agg/AggregationCombineFnAdapter.java |  24 ++
 .../extensions/sql/BeamAnalyticFunctionsTest.java  | 363 ++++++++++++++++++
 9 files changed, 895 insertions(+), 18 deletions(-)
 create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamWindowRel.java
 copy sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/{BeamValuesRule.java => BeamWindowRule.java} (64%)
 create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform/BeamBuiltinAnalyticFunctions.java
 create mode 100644 sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/BeamAnalyticFunctionsTest.java