beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [2/2] beam git commit: This closes #1824: Gives the runner access to RestrictionTracker
Date Thu, 02 Feb 2017 04:01:00 GMT
This closes #1824: Gives the runner access to RestrictionTracker


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

Branch: refs/heads/master
Commit: a27d3cfa2598eb73637d0db0babcb28548614b99
Parents: 168d6a1 7dc9e86
Author: Kenneth Knowles <klk@google.com>
Authored: Wed Feb 1 19:43:50 2017 -0800
Committer: Kenneth Knowles <klk@google.com>
Committed: Wed Feb 1 19:43:50 2017 -0800

----------------------------------------------------------------------
 .../apache/beam/runners/core/DoFnAdapters.java  |   4 +-
 ...eBoundedSplittableProcessElementInvoker.java | 285 +++++++++++++++++++
 .../beam/runners/core/SimpleDoFnRunner.java     |   6 +-
 .../beam/runners/core/SplittableParDo.java      | 190 ++-----------
 .../core/SplittableProcessElementInvoker.java   |  65 +++++
 ...ndedSplittableProcessElementInvokerTest.java | 146 ++++++++++
 .../beam/runners/core/SplittableParDoTest.java  | 147 +++++++---
 ...littableProcessElementsEvaluatorFactory.java |  66 +++--
 .../apache/beam/sdk/transforms/DoFnTester.java  |  15 +-
 .../sdk/transforms/reflect/DoFnInvoker.java     |   4 +-
 .../transforms/splittabledofn/OffsetRange.java  |  71 +++++
 .../splittabledofn/OffsetRangeTracker.java      |  75 +++++
 .../splittabledofn/RestrictionTracker.java      |   2 +-
 .../beam/sdk/transforms/SplittableDoFnTest.java |  68 +----
 .../transforms/reflect/DoFnInvokersTest.java    |   2 +-
 .../splittabledofn/OffsetRangeTrackerTest.java  | 111 ++++++++
 16 files changed, 956 insertions(+), 301 deletions(-)
----------------------------------------------------------------------



Mime
View raw message