This is an automated email from the ASF dual-hosted git repository.
ccy pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 23abb73 [BEAM-4076] Fix schemas on Dataflow and FnApi (#6072)
add 7334e56 Python PubSub updates:
add b77d2fd Fix lint errors and clarify PubsubMessage docs.
add 9153fa2 Skip unit test if pubsub is not installed.
add 0d781c3 Fix docstring indentation.
add 64120d6 Minor fixes.
new 6afa12f Merge pull request #5952 from udim/pubsub-api-2
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../examples/complete/game/game_stats.py | 4 +-
.../examples/complete/game/leader_board.py | 4 +-
.../apache_beam/examples/streaming_wordcount.py | 10 +-
.../examples/streaming_wordcount_debugging.py | 4 +-
.../apache_beam/examples/windowed_wordcount.py | 2 +-
sdks/python/apache_beam/io/gcp/pubsub.py | 205 ++++++++----
.../gcp/pubsub_integration_test.py} | 110 ++++---
.../gcp/pubsub_it_pipeline.py} | 77 ++---
sdks/python/apache_beam/io/gcp/pubsub_test.py | 348 ++++++++++++++++-----
.../apache_beam/io/gcp/tests/pubsub_matcher.py | 42 ++-
.../io/gcp/tests/pubsub_matcher_test.py | 79 ++++-
.../runners/dataflow/dataflow_runner.py | 14 +-
.../apache_beam/runners/direct/direct_runner.py | 120 +++----
.../runners/direct/transform_evaluator.py | 2 +-
sdks/python/apache_beam/utils/annotations.py | 2 +-
15 files changed, 723 insertions(+), 300 deletions(-)
copy sdks/python/apache_beam/{examples/streaming_wordcount_it_test.py =>
io/gcp/pubsub_integration_test.py} (52%)
copy sdks/python/apache_beam/{examples/streaming_wordcount.py =>
io/gcp/pubsub_it_pipeline.py} (54%)
