beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rober...@apache.org
Subject [4/4] beam git commit: Closes #2644
Date Tue, 02 May 2017 00:45:05 GMT
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 <robertwb@gmail.com>
Authored: Mon May 1 17:44:30 2017 -0700
Committer: Robert Bradshaw <robertwb@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(-)
----------------------------------------------------------------------



Mime
View raw message