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 <k...@google.com> Authored: Mon Dec 12 15:33:29 2016 -0800 Committer: Kenneth Knowles <k...@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(-) ----------------------------------------------------------------------