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 1e569fa (commit)
to ed50ac8 (commit)
from 1e569fa Merge pull request #12292 from ZijieSong946/DoubleBugFixed
add 19f1220 Improving BQ IO documentation (#12280)
add 0fb663d [BEAM-10558] Flushing of buffered elements during checkpoint
can stall
add d367600 Merge pull request #12345: [BEAM-10558] Fix flushing logic
for buffered elements during checkpoint
add f5b4179 Relax ParDo# test
add d1dde2b [BEAM-10169] Relax ParDo# test
add a73125a Re-enable checkerframework in Flink job server
add b71b5e6 Re-enable checkerframework in Spark job server
add 1771e2b Make Preconditions nullness annotations
separate-compilation-friendly
add cbd19a8 Fix preconditions nullability
add e9a7b50 Eliminate nullability issues from :sdks:java:build-tools and
enable checker
add 146ec63 Eliminate nullability issue from :sdks:java:expansion-service
and enable checker
add 8e7abb0 Merge pull request #12337: [BEAM-10555] Eliminate nullability
issues from :sdks:java:build-tools and :sdks:java:expansion-service and enable
checker
add 2eb66ef [BEAM-7996] Add support for BYTES and BOOL in Python RowCoder
(#12324)
add e9f227b [BEAM-10411] Minor fix to kafkataxi instructions
add 5a12de6 Merge pull request #12357: [BEAM-10411] Minor fix to
kafkataxi instructions
add 6d4684d [BEAM-10400] Fix race condition in DirectRunner watermark
update
add 101a493 [BEAM-10400] remove redundant state cleanup from
StatefulParDoEvaluatorFactory
add 639cb75 Merge pull request #12155: [BEAM-10400] Fix race condition in
DirectRunner watermark update
add 27876f8 Use TMPDIR or WORKSPACE if set rather than /tmp
add 48fe1b0 Update local_job_service_main call to use --stdout_file
add 63e829e Add missing dependency on java container
add 47b3d58 [BEAM-10565] Fixes for XVR_Direct (#12344)
add 803d80b [BEAM-10566] Update PythonDocker in GH README and template
add f227f40 Merge pull request #12358: [BEAM-10566] Update PythonDocker
in GH README and template
add d596cc2 Fix minor issue in the Generator type hint
add 576d164 Merge pull request #12300: [BEAM-8473] Fix minor issue in the
Generator type hint
add c33b993 Fix typos on programming-guide.md
add c70b9a6 Fixing typo on programming-guide.md
add b177711 Merge pull request #12347 from sddhrthrt/sddhrthrt-fix-typos
add a2dac5c [BEAM-7390] Add distinct code snippets
add 55dfb55 Merge pull request #12356 from davidcavazos/distinct-docs
add 13f9e89 [BEAM-7390] Add combinevalues code snippets (#12328)
add b3500c7 Disable defensive_copy by default in InMemoryUnmergedState
add ec3ca41 Merge pull request #12077 from apache/aaltay-patch-1
add 885cd0b Add relational GroupBy transform to Python. (#11963)
add 93faea7 [BEAM-10567] Updating etcd dependency in gogradle.lock
add 0984e88 Merge pull request #12364: [BEAM-10567] Updating etcd
dependency in gogradle.lock
add ed50ac8 Merge pull request #12335 from [BEAM-10378] Creates Azure
Blob Storage Resource Id
No new revisions were added by this update.
Summary of changes:
.github/PULL_REQUEST_TEMPLATE.md | 2 +-
.test-infra/jenkins/README.md | 2 +-
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 1 +
.../beam/model/fnexecution/v1/standard_coders.yaml | 22 ++
.../beam/runners/direct/EvaluationContext.java | 21 +-
.../beam/runners/direct/QuiescenceDriver.java | 43 ++-
.../direct/StatefulParDoEvaluatorFactory.java | 110 +------
.../beam/runners/direct/WatermarkManager.java | 20 +-
.../direct/StatefulParDoEvaluatorFactoryTest.java | 131 ---------
runners/flink/job-server/flink_job_server.gradle | 1 -
.../wrappers/streaming/DoFnOperator.java | 25 +-
.../wrappers/streaming/DoFnOperatorTest.java | 13 +-
runners/spark/job-server/build.gradle | 1 -
sdks/go/gogradle.lock | 216 +++++++-------
sdks/go/pkg/beam/pardo_test.go | 5 +-
sdks/java/build-tools/build.gradle | 2 +-
.../apache/beam/codestyle/CodeStyleTestClass.java | 5 +-
.../org/apache/beam/sdk/util/Preconditions.java | 95 +++---
sdks/java/expansion-service/build.gradle | 2 +-
.../sdk/expansion/service/ExpansionService.java | 81 ++++--
.../expansion/service/ExpansionServiceTest.java | 39 +--
.../beam/sdk/expansion/service/ExternalTest.java | 13 +-
sdks/java/io/azure/build.gradle | 4 +-
.../sdk/io/azure/blobstore/AzfsResourceId.java | 203 +++++++++++++
.../azure/blobstore/AzureBlobStoreFileSystem.java | 67 ++++-
.../AzureBlobStoreFileSystemRegistrar.java | 18 ++
.../beam/sdk/io/azure/blobstore}/package-info.java | 4 +-
.../sdk/io/azure/blobstore/AzfsResourceIdTest.java | 320 +++++++++++++++++++++
.../blobstore/AzureBlobStoreFileSystemTest.java | 17 --
sdks/python/apache_beam/coders/row_coder.py | 11 +-
sdks/python/apache_beam/coders/row_coder_test.py | 21 +-
.../apache_beam/coders/standard_coders_test.py | 5 +-
.../apache_beam/examples/kafkataxi/README.md | 2 +-
sdks/python/apache_beam/io/gcp/bigquery.py | 15 +-
sdks/python/apache_beam/pvalue.py | 24 ++
sdks/python/apache_beam/transforms/core.py | 162 +++++++++++
.../apache_beam/transforms/ptransform_test.py | 104 +++++++
sdks/python/apache_beam/transforms/trigger.py | 4 +-
sdks/python/apache_beam/typehints/schemas.py | 2 +
sdks/python/apache_beam/typehints/typehints.py | 2 +-
sdks/python/test-suites/direct/xlang/build.gradle | 5 +-
settings.gradle | 1 +
.../content/en/documentation/programming-guide.md | 4 +-
.../python/aggregation/combineglobally.md | 1 +
.../transforms/python/aggregation/combineperkey.md | 1 +
.../{combineperkey.md => combinevalues.md} | 69 ++---
.../transforms/python/aggregation/distinct.md | 37 ++-
.../en/documentation/transforms/python/overview.md | 1 +
.../partials/section-menu/en/documentation.html | 1 +
49 files changed, 1403 insertions(+), 552 deletions(-)
create mode 100644
sdks/java/io/azure/src/main/java/org/apache/beam/sdk/io/azure/blobstore/AzfsResourceId.java
copy
sdks/java/io/{amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/s3
=>
azure/src/main/java/org/apache/beam/sdk/io/azure/blobstore}/package-info.java
(90%)
create mode 100644
sdks/java/io/azure/src/test/java/org/apache/beam/sdk/io/azure/blobstore/AzfsResourceIdTest.java
delete mode 100644
sdks/java/io/azure/src/test/java/org/apache/beam/sdk/io/azure/blobstore/AzureBlobStoreFileSystemTest.java
copy
website/www/site/content/en/documentation/transforms/python/aggregation/{combineperkey.md
=> combinevalues.md} (79%)
