This closes #3539: Unbundle FileNamePolicy Context and WindowedContext
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5f972e8b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5f972e8b Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/5f972e8b Branch: refs/heads/master Commit: 5f972e8b2525660a2c09e6f9f21a13b5b7b46366 Parents: 889776f 64997ef Author: Kenneth Knowles <k...@google.com> Authored: Thu Jul 13 12:16:42 2017 -0700 Committer: Kenneth Knowles <k...@google.com> Committed: Thu Jul 13 12:16:42 2017 -0700 ---------------------------------------------------------------------- .../examples/common/WriteOneFilePerWindow.java | 19 +- .../complete/game/utils/WriteToText.java | 18 +- .../construction/WriteFilesTranslationTest.java | 12 +- .../beam/sdk/io/DefaultFilenamePolicy.java | 47 ++-- .../org/apache/beam/sdk/io/FileBasedSink.java | 198 ++++---------- .../java/org/apache/beam/sdk/io/AvroIOTest.java | 263 ++++++++++--------- .../apache/beam/sdk/io/FileBasedSinkTest.java | 88 +++---- .../org/apache/beam/sdk/io/WriteFilesTest.java | 122 ++++----- 8 files changed, 358 insertions(+), 409 deletions(-) ----------------------------------------------------------------------