This closes #2775
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1b0400fe Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1b0400fe Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1b0400fe Branch: refs/heads/DSL_SQL Commit: 1b0400fee088b39abb3d1b3da8877256966e6e07 Parents: 3b61f6a a7d6ddc Author: Dan Halperin <[email protected]> Authored: Wed May 3 08:09:33 2017 -0700 Committer: Dan Halperin <[email protected]> Committed: Wed May 3 08:09:33 2017 -0700 ---------------------------------------------------------------------- .../beam/runners/dataflow/util/GcsStager.java | 26 ++-- .../beam/runners/dataflow/util/PackageUtil.java | 38 +++-- .../runners/dataflow/DataflowRunnerTest.java | 20 ++- .../runners/dataflow/util/PackageUtilTest.java | 143 ++++++++++++------- .../org/apache/beam/sdk/io/FileSystems.java | 28 ++-- .../gcp/storage/GcsCreateOptions.java | 56 ++++++++ .../extensions/gcp/storage/GcsFileSystem.java | 7 +- .../java/org/apache/beam/sdk/util/GcsUtil.java | 12 +- 8 files changed, 224 insertions(+), 106 deletions(-) ----------------------------------------------------------------------
