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 9876fe4 (commit)
to 55b8b8c (commit)
from 9876fe4 Merge pull request #15565 from y1chi/beam-12898-fix
add 0cc41e1 Add missing comma
add f351428 Merge pull request #15581 from [BEAM-12943] Add missing comma
in dataframes.ipynb
add 7dd14df Update tensorflow to version 2.6.0
add d51180a [BEAM-12869] Update tensorflow version to 2.6.0 and protobuf
to 3.17.3. #15583
add e7220ca Cleanup use of futures. (#15043)
add 5eecec8 [BEAM-12934] Use environment capabilities to determine length
prefixing.
add 6915d7d Merge pull request #15550 [BEAM-12934] Use environment
capabilities to determine length prefixing.
add 7cbecc1 Go Lint fix for wordcount and metrics (#15580)
add f3b67e7 Fix whitespace lint
add 1965eba Merge pull request #15589 from TheNeuralBit/fix-whitespace
add e70366d [BEAM-3304] Snippets for trigger in BPG (#15409)
add 56df849 [BEAM-12832] Add Go SDK xlang info to programming guide.
(#15447)
add 533a632 [BEAM-9487] Fix incorrected Repeatedly.may_finish
implementation
add e2030d8 Merge pull request #15586: [BEAM-9487] Fix incorrect
Repeatedly.may_lose_data implementation
add f051cd9 [BEAM-11097] Add SideInputCache to StateReader (#15563)
add 818ee3b Revert "Avoid apiary submission of job graph when it is not
needed. (#15458)"
add f11a5bb Merge pull request #15592 from robertwb/no-upload-graph
add 210ede6 [BEAM-12769] Java-emulating external transform. (#15546)
add 55b8b8c [BEAM-12913] Pass query priority from ReadAllFromBigQuery
(#15584)
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 4 +-
examples/notebooks/tour-of-beam/dataframes.ipynb | 2 +-
.../go/examples/snippets/{doc.go => 09triggers.go} | 32 +++++++
sdks/go/examples/wordcount/wordcount.go | 16 ++--
sdks/go/pkg/beam/core/metrics/metrics.go | 4 +-
sdks/go/pkg/beam/core/runtime/exec/data.go | 4 +
sdks/go/pkg/beam/core/runtime/harness/harness.go | 2 +-
.../core/runtime/harness/statecache/statecache.go | 22 ++++-
.../runtime/harness/statecache/statecache_test.go | 3 +-
sdks/go/pkg/beam/core/runtime/harness/statemgr.go | 15 ++-
sdks/go/pkg/beam/runners/direct/direct.go | 2 +-
.../fn/harness/control/ProcessBundleHandler.java | 8 +-
.../apache/beam/fn/harness/state/BagUserState.java | 8 +-
.../beam/fn/harness/state/BeamFnStateClient.java | 5 +-
.../harness/state/BeamFnStateGrpcClientCache.java | 5 +-
.../fn/harness/state/CachingBeamFnStateClient.java | 21 ++---
.../beam/fn/harness/state/MultimapUserState.java | 31 +++---
.../fn/harness/state/StateFetchingIterators.java | 18 ++--
.../harness/control/ProcessBundleHandlerTest.java | 30 +++---
.../state/BeamFnStateGrpcClientCacheTest.java | 25 +++--
.../state/CachingBeamFnStateClientTest.java | 16 +---
.../fn/harness/state/FakeBeamFnStateClient.java | 7 +-
.../harness/state/StateFetchingIteratorsTest.java | 45 +++++++--
sdks/python/apache_beam/io/gcp/bigquery.py | 7 +-
.../apache_beam/io/gcp/bigquery_read_internal.py | 5 +-
.../runners/dataflow/dataflow_runner.py | 7 --
.../portability/fn_api_runner/translations.py | 29 +++++-
sdks/python/apache_beam/transforms/external.py | 46 ++++++++-
.../python/apache_beam/transforms/external_test.py | 37 ++++++++
sdks/python/apache_beam/transforms/trigger.py | 11 +--
sdks/python/apache_beam/transforms/trigger_test.py | 7 +-
sdks/python/container/base_image_requirements.txt | 6 +-
.../container/license_scripts/dep_urls_py.yaml | 2 +
.../content/en/documentation/programming-guide.md | 105 +++++++++++++++++++--
34 files changed, 428 insertions(+), 159 deletions(-)
copy sdks/go/examples/snippets/{doc.go => 09triggers.go} (51%)
