nsivabalan commented on a change in pull request #3977:
URL: https://github.com/apache/hudi/pull/3977#discussion_r773618478
##########
File path:
hudi-common/src/test/java/org/apache/hudi/common/fs/inline/TestInLineFileSystem.java
##########
@@ -296,6 +296,64 @@ public void testsetWorkingDirectory() throws IOException {
}, "Should have thrown exception");
}
+ static class TestFSPath {
+ final Path inputPath;
+ final Path expectedInLineFSPath;
+ final Path transformedInputPath;
+
+ TestFSPath(final Path inputPath, final Path expectedInLineFSPath, final
Path transformedInputPath) {
+ this.inputPath = inputPath;
+ this.expectedInLineFSPath = expectedInLineFSPath;
+ this.transformedInputPath = transformedInputPath;
+ }
+ }
+
+ @Test
+ public void testInLineFSPathConversions() {
+ final List<TestFSPath> expectedInLinePaths = Arrays.asList(
+ new TestFSPath(
+ new Path("/zero/524bae7e-f01d-47ae-b7cd-910400a81336"),
+ new
Path("inlinefs://zero/524bae7e-f01d-47ae-b7cd-910400a81336/file/?start_offset=10&length=10"),
+ new Path("file:/zero/524bae7e-f01d-47ae-b7cd-910400a81336")),
+ new TestFSPath(
+ new Path("file:/one/524bae7e-f01d-47ae-b7cd-910400a81336"),
+ new
Path("inlinefs://one/524bae7e-f01d-47ae-b7cd-910400a81336/file/?start_offset=10&length=10"),
+ new Path("file:/one/524bae7e-f01d-47ae-b7cd-910400a81336")),
+ new TestFSPath(
+ new Path("file://two/524bae7e-f01d-47ae-b7cd-910400a81336"),
+ new
Path("inlinefs://two/524bae7e-f01d-47ae-b7cd-910400a81336/file/?start_offset=10&length=10"),
+ new Path("file:/two/524bae7e-f01d-47ae-b7cd-910400a81336")),
+ new TestFSPath(
Review comment:
@vinothchandar : here are examples for hdfs path conversion to inline
paths.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
