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/12/12 23:34:24 UTC

[4/4] incubator-beam git commit: This closes #1536

This closes #1536


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

Branch: refs/heads/master
Commit: d9657ffc37490b063835672e0b5287b4d18aba96
Parents: 59f1fb2 42595dc
Author: Kenneth Knowles <kl...@google.com>
Authored: Mon Dec 12 15:33:29 2016 -0800
Committer: Kenneth Knowles <kl...@google.com>
Committed: Mon Dec 12 15:33:29 2016 -0800

----------------------------------------------------------------------
 .../apache/beam/examples/WindowedWordCount.java | 177 ++++++++-------
 .../examples/common/WriteWindowedFilesDoFn.java |  77 +++++++
 .../beam/examples/WindowedWordCountIT.java      | 182 ++++++++++++---
 .../apache/beam/sdk/coders/CoderRegistry.java   |   2 +
 .../beam/sdk/testing/FileChecksumMatcher.java   | 114 ++--------
 .../beam/sdk/util/ExplicitShardedFile.java      | 120 ++++++++++
 .../beam/sdk/util/NumberedShardedFile.java      | 220 +++++++++++++++++++
 .../org/apache/beam/sdk/util/ShardedFile.java   |  42 ++++
 .../sdk/testing/FileChecksumMatcherTest.java    |  77 -------
 .../beam/sdk/util/NumberedShardedFileTest.java  | 181 +++++++++++++++
 10 files changed, 909 insertions(+), 283 deletions(-)
----------------------------------------------------------------------