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 a48abeb (commit)
to 3f12f8b (commit)
from a48abeb Merge pull request #14384 from [BEAM-10861] Change
PubSubSource and PubSubSink translation to avoid special transform overrides
add f49e097 [BEAM-12128] replace usage of snippets_test_py3.py to
snippets_test.py (#14488)
add b28373b [BEAM-12141] Print sha256 and size when downloading artifacts
via artifact retrieval service
add 974c2de Merge pull request #14492 from ihji/BEAM-12141
add 4805a62 Decrease the memorized backlog from 5s to 1s
add cae0652 Merge pull request #14478: Decrease the memorized backlog
from 5s to 1s
add 5f9f659 [BEAM-11546] Cross-language pipeline pattern
add ed3df93 Merge pull request #13642: [BEAM-11546] Cross-language
pipeline pattern
add 66c93a2 No build cache
add d40cdc4 Revert build cache change
add 1472c5b [BEAM-11483] Spark PostCommit Test Improvements - creating
one Jenkins job per Gradle task (#14483)
add 1b86266 [BEAM-12104] Pin Dataflow wordcount to ubuntu 18.04 (#14451)
add 9a9d10a Avoid multiple lookups in ConcurrentHashMap by utilizing
compute* methods instead of chained get/put. (#14494)
add d3cfb71 Optimize ExecutionStateTracker reset to not iterate over all
trackers (#14495)
add 476c2b1 [BEAM-12142] Reduce ThreadLocal interaction with
MetricsEnvironment by leaving unchanging (#14498)
add 43fba5f [BEAM-12117] When reusing QueueingBeamFnDataClient, reset it
to avoid its set of inbound clients from growing without bound. (#14458)
add 2408d0c Remove references to deprecated methods fromstring and
tostring (#14453)
add 39923d8 Misc sphinx fixes (#14485)
add 8450ca6 [BEAM-12024] Move examples.wordcount_dataframe to
examples.dataframe, add taxiride example (#14308)
add 3f12f8b [BEAM-9547] Implement Series.is_unique property (#14361)
No new revisions were added by this update.
Summary of changes:
.github/workflows/java_tests.yml | 4 +-
...ortableValidatesRunner_Spark2_Streaming.groovy} | 7 +-
...ortableValidatesRunner_Spark3_Streaming.groovy} | 7 +-
.../core/metrics/ExecutionStateTracker.java | 8 +-
.../core/metrics/MetricsContainerStepMap.java | 27 ++--
sdks/go/pkg/beam/artifact/materialize.go | 18 ++-
.../beam/sdk/metrics/MetricsEnvironment.java | 33 ++--
.../beam/sdk/metrics/MetricsEnvironmentTest.java | 36 ++++-
.../fn/harness/control/ProcessBundleHandler.java | 1 +
.../fn/harness/data/QueueingBeamFnDataClient.java | 68 +++++---
.../beam/sdk/io/kafka/ReadFromKafkaDoFn.java | 2 +-
sdks/python/apache_beam/coders/row_coder.py | 4 +-
sdks/python/apache_beam/dataframe/frames.py | 28 ++++
sdks/python/apache_beam/dataframe/frames_test.py | 10 ++
.../apache_beam/examples/dataframe/taxiride.py | 122 ++++++++++++++
.../examples/dataframe/taxiride_test.py | 127 +++++++++++++++
.../wordcount.py} | 5 +-
.../wordcount_test.py} | 5 +-
.../apache_beam/examples/wordcount_dataframe.py | 59 +------
sdks/python/scripts/generate_pydoc.sh | 51 +++---
sdks/python/tox.ini | 2 +-
.../en/documentation/patterns/cross-language.md | 175 +++++++++++++++++++++
.../content/en/documentation/patterns/overview.md | 3 +
.../en/documentation/sdks/python-type-safety.md | 8 +-
.../partials/section-menu/en/documentation.html | 1 +
25 files changed, 647 insertions(+), 164 deletions(-)
copy
.test-infra/jenkins/{job_PostCommit_Java_PortableValidatesRunner_Spark_Streaming.groovy
=> job_PostCommit_Java_PortableValidatesRunner_Spark2_Streaming.groovy} (86%)
rename
.test-infra/jenkins/{job_PostCommit_Java_PortableValidatesRunner_Spark_Streaming.groovy
=> job_PostCommit_Java_PortableValidatesRunner_Spark3_Streaming.groovy} (86%)
create mode 100644 sdks/python/apache_beam/examples/dataframe/taxiride.py
create mode 100644 sdks/python/apache_beam/examples/dataframe/taxiride_test.py
copy sdks/python/apache_beam/examples/{wordcount_dataframe.py =>
dataframe/wordcount.py} (94%)
rename sdks/python/apache_beam/examples/{wordcount_dataframe_test.py =>
dataframe/wordcount_test.py} (92%)
create mode 100644
website/www/site/content/en/documentation/patterns/cross-language.md
