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

Posted to commits@beam.apache.org by re...@apache.org on 2018/10/08 08:12:56 UTC

[beam] 01/01: Merge pull request #6298: [BEAM-4461] Introduce Group transform.

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

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

commit 478800a3d53ee1881e6d4292f95b036fe7ee9665
Merge: 8fdbc09 77291e8
Author: reuvenlax <re...@google.com>
AuthorDate: Mon Oct 8 01:12:48 2018 -0700

    Merge pull request #6298: [BEAM-4461] Introduce Group transform.

 .../org/apache/beam/sdk/coders/CoderRegistry.java  |   3 +-
 .../java/org/apache/beam/sdk/coders/RowCoder.java  |  47 +-
 .../beam/sdk/schemas/FieldTypeDescriptors.java     |   2 +-
 .../beam/sdk/schemas/transforms/Convert.java       |   4 -
 .../apache/beam/sdk/schemas/transforms/Group.java  | 684 +++++++++++++++++++++
 .../sdk/schemas/transforms/SchemaAggregateFn.java  | 318 ++++++++++
 .../apache/beam/sdk/schemas/transforms/Select.java |   6 +-
 .../org/apache/beam/sdk/transforms/Combine.java    |  11 +
 .../org/apache/beam/sdk/values/PCollection.java    |  20 +-
 .../beam/sdk/schemas/transforms/GroupTest.java     | 646 +++++++++++++++++++
 .../beam/sdk/schemas/transforms/SelectTest.java    |   1 -
 .../impl/transform/BeamAggregationTransforms.java  |   9 +-
 12 files changed, 1732 insertions(+), 19 deletions(-)