You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2017/04/28 18:05:36 UTC
[1/2] beam git commit: [BEAM-2119] Fix FileSystems to have the local
filesystem installed by default.
Repository: beam
Updated Branches:
refs/heads/master a8a04a290 -> 1a265e34f
[BEAM-2119] Fix FileSystems to have the local filesystem installed by default.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3423bfd4
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3423bfd4
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3423bfd4
Branch: refs/heads/master
Commit: 3423bfd48a3f44e0b58eaef870b6adae45db3af6
Parents: a8a04a2
Author: Luke Cwik <lc...@google.com>
Authored: Fri Apr 28 10:55:52 2017 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Fri Apr 28 10:57:54 2017 -0700
----------------------------------------------------------------------
.../core/src/main/java/org/apache/beam/sdk/io/FileSystems.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/3423bfd4/sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileSystems.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileSystems.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileSystems.java
index 532a42f..c41ee48 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileSystems.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileSystems.java
@@ -69,7 +69,8 @@ public class FileSystems {
"(?<scheme>[a-zA-Z][-a-zA-Z0-9+.]*)://.*");
private static final AtomicReference<Map<String, FileSystem>> SCHEME_TO_FILESYSTEM =
- new AtomicReference<>();
+ new AtomicReference<Map<String, FileSystem>>(
+ ImmutableMap.<String, FileSystem>of("file", new LocalFileSystem()));
/********************************** METHODS FOR CLIENT **********************************/
[2/2] beam git commit: [BEAM-2119] Fix FileSystems to have the local
filesystem installed by default.
Posted by lc...@apache.org.
[BEAM-2119] Fix FileSystems to have the local filesystem installed by default.
This closes #2765
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1a265e34
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1a265e34
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1a265e34
Branch: refs/heads/master
Commit: 1a265e34f31a32300515c454c619a26d61ba2482
Parents: a8a04a2 3423bfd
Author: Luke Cwik <lc...@google.com>
Authored: Fri Apr 28 11:01:50 2017 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Fri Apr 28 11:01:50 2017 -0700
----------------------------------------------------------------------
.../core/src/main/java/org/apache/beam/sdk/io/FileSystems.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------