You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2021/05/01 02:49:17 UTC

[beam] tag nightly-master updated (0302dcd -> d9da8a4)

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

github-bot pushed a change to tag nightly-master
in repository https://gitbox.apache.org/repos/asf/beam.git.


*** WARNING: tag nightly-master was modified! ***

    from 0302dcd  (commit)
      to d9da8a4  (commit)
    from 0302dcd  Merge pull request #14681 from ihji/changes_2_31_0
     add 871dbbc  [BEAM-12147][BEAM-9919] Add Go SDK x-lang prefix transform
     add b7d8569  Merge pull request #14666: [BEAM-12147][BEAM-9919] Add Go SDK x-lang prefix transform
     add 6bca47d  [BEAM-12223] Fix javadoc bug in JdbcIO (#14642)
     add 39840ba  [BEAM-12252] Bump kotlin version to 1.4.32 and improve Kotlin code
     add 25cf1d4  [BEAM-12252] upgrade kotlin version for example (#14679)
     add 1583344  [BEAM-12165] Add support for ParquetIO Sink to specify an Avro model (#14644)
     add f5f9898  [BEAM-12018] Initial implementation for melt (#14689)
     add 24d6cda  [BEAM-12257] Infer accumulator coder from underlying AggregateFn in LazyAggregateCombineFn.
     add 7e1aa0d  Merge pull request #14693 from ibzib/accum-coder
     add 299cf1a  Updates transform overriding to support parent/child external transforms
     add 4bd217c  Merge pull request #14692: [BEAM-12242] Updates transform overriding to support parent/child external transforms
     add d9da8a4  Merge pull request #13617 from [BEAM-11289] [Python] Integrate Google Cloud Recommendations AI functionality

No new revisions were added by this update.

Summary of changes:
 examples/kotlin/build.gradle                       |   2 +-
 .../kotlin/common/WriteOneFilePerWindow.kt         |   2 +-
 .../examples/kotlin/cookbook/DistinctExample.kt    |   2 +-
 .../examples/kotlin/cookbook/TriggerExample.kt     |   1 -
 sdks/go/examples/xlang/transforms.go               |  31 ++
 sdks/go/pkg/beam/core/runtime/xlangx/payload.go    |  67 +++
 sdks/go/pkg/beam/xlang.go                          |  11 +
 sdks/go/test/integration/integration.go            |   1 +
 sdks/go/test/integration/xlang/xlang_test.go       |  15 +
 sdks/go/test/run_validatesrunner_tests.sh          |   8 +-
 .../sql/impl/LazyAggregateCombineFn.java           |  31 ++
 .../sql/impl/LazyAggregateCombineFnTest.java       |  69 +++
 .../java/org/apache/beam/sdk/io/jdbc/JdbcIO.java   |  10 +-
 .../org/apache/beam/sdk/io/parquet/ParquetIO.java  |  20 +
 .../apache/beam/sdk/io/parquet/ParquetIOTest.java  |  47 ++
 sdks/python/apache_beam/dataframe/frames.py        |  16 +
 sdks/python/apache_beam/dataframe/frames_test.py   |  43 ++
 .../apache_beam/dataframe/pandas_doctests_test.py  |  17 +-
 .../apache_beam/ml/gcp/recommendations_ai.py       | 585 +++++++++++++++++++++
 .../apache_beam/ml/gcp/recommendations_ai_test.py  | 207 ++++++++
 .../ml/gcp/recommendations_ai_test_it.py           | 107 ++++
 sdks/python/apache_beam/pipeline.py                |  25 +-
 sdks/python/apache_beam/transforms/external.py     |   8 +-
 .../python/apache_beam/transforms/external_test.py |  57 ++
 sdks/python/setup.py                               |   1 +
 25 files changed, 1366 insertions(+), 17 deletions(-)
 create mode 100644 sdks/go/pkg/beam/core/runtime/xlangx/payload.go
 create mode 100644 sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/impl/LazyAggregateCombineFnTest.java
 create mode 100644 sdks/python/apache_beam/ml/gcp/recommendations_ai.py
 create mode 100644 sdks/python/apache_beam/ml/gcp/recommendations_ai_test.py
 create mode 100644 sdks/python/apache_beam/ml/gcp/recommendations_ai_test_it.py