Repository: incubator-beam Updated Branches: refs/heads/master 9cdaed0d8 -> adb472083
[BEAM-316] Add file scheme support in TextIO Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7337ecf1 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7337ecf1 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/7337ecf1 Branch: refs/heads/master Commit: 7337ecf147ca69262978db116a5a1f739aca28ae Parents: 9cdaed0 Author: Jean-Baptiste Onofré <[email protected]> Authored: Tue May 31 18:04:52 2016 +0200 Committer: Dan Halperin <[email protected]> Committed: Thu Jul 21 20:17:53 2016 -0700 ---------------------------------------------------------------------- .../main/java/org/apache/beam/sdk/util/IOChannelUtils.java | 1 + .../java/org/apache/beam/sdk/util/IOChannelUtilsTest.java | 7 +++++++ 2 files changed, 8 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/7337ecf1/sdks/java/core/src/main/java/org/apache/beam/sdk/util/IOChannelUtils.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/util/IOChannelUtils.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/util/IOChannelUtils.java index efb0ff6..913824d 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/util/IOChannelUtils.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/util/IOChannelUtils.java @@ -63,6 +63,7 @@ public class IOChannelUtils { */ public static void registerStandardIOFactories(PipelineOptions options) { setIOFactory("gs", new GcsIOChannelFactory(options.as(GcsOptions.class))); + setIOFactory("file", new FileIOChannelFactory()); } /** http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/7337ecf1/sdks/java/core/src/test/java/org/apache/beam/sdk/util/IOChannelUtilsTest.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/util/IOChannelUtilsTest.java b/sdks/java/core/src/test/java/org/apache/beam/sdk/util/IOChannelUtilsTest.java index 12312d1..9168fd6 100644 --- a/sdks/java/core/src/test/java/org/apache/beam/sdk/util/IOChannelUtilsTest.java +++ b/sdks/java/core/src/test/java/org/apache/beam/sdk/util/IOChannelUtilsTest.java @@ -80,6 +80,13 @@ public class IOChannelUtilsTest { } @Test + public void testFilePrefix() throws Exception { + IOChannelUtils.getFactory("file://tmp"); + IOChannelUtils.getFactory("file:/tmp"); + IOChannelUtils.getFactory("file:tmp"); + } + + @Test public void testGetSizeBytes() throws Exception { String data = "TestData"; File file = tmpFolder.newFile();
