You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2016/05/19 19:04:19 UTC
[3/3] incubator-beam git commit: This closes #268
This closes #268
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/2f18cd26
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/2f18cd26
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/2f18cd26
Branch: refs/heads/master
Commit: 2f18cd2687a4dad0510bb29cd62c9dd2323ee70b
Parents: f184bcf aad284a
Author: Kenneth Knowles <kl...@google.com>
Authored: Thu May 19 11:53:49 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Thu May 19 11:53:49 2016 -0700
----------------------------------------------------------------------
.../beam/runners/direct/BundleFactory.java | 2 +-
.../direct/GroupByKeyEvaluatorFactory.java | 274 -------------------
.../direct/InProcessEvaluationContext.java | 2 +-
...rocessGroupAlsoByWindowEvaluatorFactory.java | 127 +++++++++
.../runners/direct/InProcessGroupByKey.java | 132 +++++++++
...InProcessGroupByKeyOnlyEvaluatorFactory.java | 183 +++++++++++++
.../InProcessGroupByKeyOverrideFactory.java | 41 +++
.../runners/direct/InProcessPipelineRunner.java | 3 +-
.../direct/TransformEvaluatorRegistry.java | 8 +-
.../direct/GroupByKeyEvaluatorFactoryTest.java | 4 +-
...ocessGroupByKeyOnlyEvaluatorFactoryTest.java | 183 +++++++++++++
.../beam/sdk/util/KeyedWorkItemCoder.java | 8 +
12 files changed, 684 insertions(+), 283 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/2f18cd26/runners/direct-java/src/main/java/org/apache/beam/runners/direct/InProcessEvaluationContext.java
----------------------------------------------------------------------