beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [3/3] incubator-beam git commit: This closes #268
Date Thu, 19 May 2016 19:04:19 GMT
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 <klk@google.com>
Authored: Thu May 19 11:53:49 2016 -0700
Committer: Kenneth Knowles <klk@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
----------------------------------------------------------------------


Mime
View raw message