beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [4/4] incubator-beam git commit: This closes #697
Date Mon, 25 Jul 2016 19:11:48 GMT
This closes #697


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

Branch: refs/heads/master
Commit: 7809f6bd2cd3605ce389a174aba242ea08860f88
Parents: cf14644 902997d
Author: Kenneth Knowles <klk@google.com>
Authored: Mon Jul 25 12:11:27 2016 -0700
Committer: Kenneth Knowles <klk@google.com>
Committed: Mon Jul 25 12:11:27 2016 -0700

----------------------------------------------------------------------
 .../core/GroupAlsoByWindowViaWindowSetDoFn.java | 16 ++--
 .../beam/sdk/util/GroupAlsoByWindowsDoFn.java   | 10 ++-
 .../GroupAlsoByWindowsViaOutputBufferDoFn.java  | 10 +--
 .../sdk/util/GroupByKeyViaGroupByKeyOnly.java   | 79 +++++++++++++++++---
 .../sdk/util/GroupAlsoByWindowsProperties.java  | 50 +++++++++++--
 ...oupAlsoByWindowsViaOutputBufferDoFnTest.java |  8 +-
 .../GroupAlsoByWindowEvaluatorFactory.java      | 30 ++++++++
 .../beam/runners/direct/ParDoEvaluator.java     |  4 +-
 .../direct/ParDoMultiEvaluatorFactory.java      |  6 ++
 .../direct/ParDoSingleEvaluatorFactory.java     |  6 ++
 .../direct/WriteWithShardingFactory.java        |  7 +-
 .../beam/runners/direct/ParDoEvaluatorTest.java |  1 +
 .../FlinkGroupAlsoByWindowWrapper.java          | 31 +++++---
 .../spark/translation/TransformTranslator.java  | 70 ++++++++++++++++-
 .../apache/beam/sdk/transforms/DoFnTester.java  | 41 +++++++++-
 .../sdk/util/state/StateInternalsFactory.java   | 36 +++++++++
 16 files changed, 349 insertions(+), 56 deletions(-)
----------------------------------------------------------------------



Mime
View raw message