This closes #3454
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2dd1907c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2dd1907c Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2dd1907c Branch: refs/heads/master Commit: 2dd1907c65cdd04f2a54f2ef1368ee39f72c19fe Parents: 4d41e25 fb7ec28 Author: Ahmet Altay <al...@google.com> Authored: Thu Jun 29 09:46:07 2017 -0700 Committer: Ahmet Altay <al...@google.com> Committed: Thu Jun 29 09:46:07 2017 -0700 ---------------------------------------------------------------------- .../apache_beam/examples/streaming_wordcount.py | 12 ++- sdks/python/apache_beam/io/gcp/pubsub.py | 91 +++++++++++++++----- sdks/python/apache_beam/io/gcp/pubsub_test.py | 89 +++++++++++-------- .../runners/dataflow/dataflow_runner.py | 11 +-- .../apache_beam/runners/direct/direct_runner.py | 54 ++++++++++++ .../runners/direct/transform_evaluator.py | 89 +++++++++++++++++++ 6 files changed, 281 insertions(+), 65 deletions(-) ----------------------------------------------------------------------
