beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dhalp...@apache.org
Subject [3/3] incubator-beam git commit: Closes #598
Date Mon, 18 Jul 2016 16:52:31 GMT
Closes #598


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7e0497bb
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7e0497bb
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/7e0497bb

Branch: refs/heads/python-sdk
Commit: 7e0497bb6c15517deb85dcca30f9ea26d5ec0e2d
Parents: b8e3a7b 4f64d0a
Author: Dan Halperin <dhalperi@google.com>
Authored: Mon Jul 18 09:51:54 2016 -0700
Committer: Dan Halperin <dhalperi@google.com>
Committed: Mon Jul 18 09:51:54 2016 -0700

----------------------------------------------------------------------
 sdks/python/apache_beam/io/fileio.py            |   6 +
 .../apache_beam/runners/inprocess/__init__.py   |  19 +
 .../runners/inprocess/bundle_factory.py         | 102 ++++
 .../apache_beam/runners/inprocess/clock.py      |  50 ++
 .../consumer_tracking_pipeline_visitor.py       |  59 ++
 .../consumer_tracking_pipeline_visitor_test.py  | 122 ++++
 .../inprocess/inprocess_evaluation_context.py   | 297 ++++++++++
 .../runners/inprocess/inprocess_executor.py     | 550 +++++++++++++++++++
 .../runners/inprocess/inprocess_runner.py       | 142 +++++
 .../runners/inprocess/inprocess_runner_test.py  | 117 ++++
 .../inprocess/inprocess_transform_result.py     |  60 ++
 .../inprocess/inprocess_watermark_manager.py    | 224 ++++++++
 .../runners/inprocess/transform_evaluator.py    | 543 ++++++++++++++++++
 13 files changed, 2291 insertions(+)
----------------------------------------------------------------------



Mime
View raw message