This closes #3161: [BEAM-2302] Add spilling code to WriteFiles.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/698b89e2 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/698b89e2 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/698b89e2 Branch: refs/heads/master Commit: 698b89e2b5b88403a5c762b039d3ec8c48b25b26 Parents: 10e4764 69b01a6 Author: Eugene Kirpichov <kirpic...@google.com> Authored: Tue Jun 20 14:28:39 2017 -0700 Committer: Eugene Kirpichov <kirpic...@google.com> Committed: Tue Jun 20 14:28:39 2017 -0700 ---------------------------------------------------------------------- runners/direct-java/pom.xml | 3 +- .../beam/runners/direct/DirectRunner.java | 28 ++-- .../java/org/apache/beam/sdk/io/WriteFiles.java | 133 +++++++++++++++---- .../beam/sdk/testing/TestPipelineOptions.java | 10 ++ .../java/org/apache/beam/sdk/io/SimpleSink.java | 4 + .../org/apache/beam/sdk/io/WriteFilesTest.java | 89 ++++++++++--- 6 files changed, 209 insertions(+), 58 deletions(-) ----------------------------------------------------------------------
