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