You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ro...@apache.org on 2017/05/02 00:45:05 UTC
[4/4] beam git commit: Closes #2644
Closes #2644
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7c425b09
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7c425b09
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7c425b09
Branch: refs/heads/master
Commit: 7c425b097fdadcc160cdaa7d8992416b991e37c4
Parents: b8131fe a856fcf
Author: Robert Bradshaw <ro...@gmail.com>
Authored: Mon May 1 17:44:30 2017 -0700
Committer: Robert Bradshaw <ro...@gmail.com>
Committed: Mon May 1 17:44:30 2017 -0700
----------------------------------------------------------------------
.../apache_beam/runners/portability/__init__.py | 16 +
.../runners/portability/fn_api_runner.py | 471 ++++++++++++++
.../runners/portability/fn_api_runner_test.py | 40 ++
.../portability/maptask_executor_runner.py | 468 +++++++++++++
.../portability/maptask_executor_runner_test.py | 204 ++++++
.../apache_beam/runners/worker/__init__.py | 16 +
.../apache_beam/runners/worker/data_plane.py | 288 ++++++++
.../runners/worker/data_plane_test.py | 139 ++++
.../apache_beam/runners/worker/log_handler.py | 100 +++
.../runners/worker/log_handler_test.py | 105 +++
.../apache_beam/runners/worker/logger.pxd | 25 +
.../python/apache_beam/runners/worker/logger.py | 173 +++++
.../apache_beam/runners/worker/logger_test.py | 182 ++++++
.../apache_beam/runners/worker/opcounters.pxd | 45 ++
.../apache_beam/runners/worker/opcounters.py | 162 +++++
.../runners/worker/opcounters_test.py | 149 +++++
.../runners/worker/operation_specs.py | 368 +++++++++++
.../apache_beam/runners/worker/operations.pxd | 89 +++
.../apache_beam/runners/worker/operations.py | 651 +++++++++++++++++++
.../apache_beam/runners/worker/sdk_worker.py | 451 +++++++++++++
.../runners/worker/sdk_worker_main.py | 62 ++
.../runners/worker/sdk_worker_test.py | 168 +++++
.../apache_beam/runners/worker/sideinputs.py | 166 +++++
.../runners/worker/sideinputs_test.py | 150 +++++
.../apache_beam/runners/worker/statesampler.pyx | 237 +++++++
.../runners/worker/statesampler_fake.py | 34 +
.../runners/worker/statesampler_test.py | 102 +++
sdks/python/generate_pydoc.sh | 2 +
sdks/python/setup.py | 8 +-
29 files changed, 5069 insertions(+), 2 deletions(-)
----------------------------------------------------------------------