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 7c0c048 (commit)
to d59b1a0 (commit)
from 7c0c048 Merge pull request #15362: [BEAM-9379] Remove Java11 specific
SQL timeout
add 2a6601b [Go SDK] Go SDK Exits Experimental (#15374)
add 7611831 [BEAM-12724][BEAM-12349] Support user timers in Samza
portable runner (#15349)
add 292dc44 Decreasing peak memory usage for
`beam.TupleCombineFn.merge_accumulators`.
add 12d624b Changing the default `merge_accumulators_batch_size`
add 4559c75 Merge pull request #15271 Decreasing peak memory usage for
beam.TupleCombineFn.
add 13754d4 Clarify PCollection immutability. (#15227)
add 76d0dcb [BEAM-11218] ptest allows to obtain a pipeline result (#15364)
add 6b65b3c Remove trailing whitespace
add c439abf Merge pull request #15383 from ibzib/whitespace
add 85d46e1 Merge pull request #15357 from [BEAM-12781] Add memoization
of BoundedSource encoding for SDFBoundedSourceReader
add 0145d28 [BEAM-9615] Report Row as Known URN
add d59b1a0 Merge pull request #15384: [BEAM-9615] Report Row as Known URN
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 15 ++++
runners/samza/job-server/build.gradle | 2 -
.../apache/beam/runners/samza/runtime/DoFnOp.java | 22 +++---
.../runtime/DoFnRunnerWithKeyedInternals.java | 39 ++++------
.../runners/samza/runtime/SamzaDoFnRunners.java | 59 ++++++++++++++-
.../samza/translation/GroupByKeyTranslator.java | 5 +-
.../translation/ParDoBoundMultiTranslator.java | 7 +-
.../translation/PortableTranslationContext.java | 53 +------------
.../beam/runners/samza/util/WindowUtils.java | 74 ++++++++++++++++++
.../beam/runners/samza/util/WindowUtilsTest.java | 87 ++++++++++++++++++++++
sdks/go.mod | 3 +
sdks/go/BUILD.md | 43 ++++++-----
sdks/go/README.md | 67 ++++-------------
sdks/go/pkg/beam/core/metrics/metrics.go | 66 ++++++++++++++++
sdks/go/pkg/beam/core/runtime/graphx/coder.go | 2 +-
sdks/go/pkg/beam/runners/direct/direct.go | 24 +++++-
sdks/go/pkg/beam/testing/ptest/ptest.go | 15 +++-
.../test/integration/wordcount/wordcount_test.go | 3 +-
sdks/python/apache_beam/coders/coders.py | 43 +++++++++++
.../apache_beam/coders/coders_test_common.py | 4 +
.../apache_beam/io/gcp/bigquery_write_it_test.py | 2 +-
sdks/python/apache_beam/io/iobase.py | 24 +++++-
.../runners/portability/samza_runner_test.py | 24 +-----
sdks/python/apache_beam/transforms/combiners.py | 34 +++++++--
.../apache_beam/transforms/combiners_test.py | 38 +++++++++-
.../content/en/documentation/programming-guide.md | 9 ++-
.../documentation/resources/learning-resources.md | 2 +-
.../www/site/content/en/documentation/sdks/go.md | 12 ++-
.../site/content/en/get-started/quickstart-go.md | 4 +-
29 files changed, 565 insertions(+), 217 deletions(-)
create mode 100644
runners/samza/src/main/java/org/apache/beam/runners/samza/util/WindowUtils.java
create mode 100644
runners/samza/src/test/java/org/apache/beam/runners/samza/util/WindowUtilsTest.java
