@Test public void testOpen() throws IOException { Path inlinePath = getRandomInlinePath(); assertThrows(FileNotFoundException.class, () -> { inlinePath.getFileSystem(conf).open(inlinePath); }, "Should have thrown exception"); }
@Override public FSDataInputStream open(Path inlinePath, int bufferSize) throws IOException { Path outerPath = InLineFSUtils.getOuterfilePathFromInlinePath(inlinePath); FileSystem outerFs = outerPath.getFileSystem(conf); FSDataInputStream outerStream = outerFs.open(outerPath, bufferSize); return new InLineFsDataInputStream(InLineFSUtils.startOffset(inlinePath), outerStream, InLineFSUtils.length(inlinePath)); }
InLineFileSystem extends FileSystem { @Override public FSDataInputStream open(Path inlinePath, int bufferSize) throws IOException { Path outerPath = InLineFSUtils.getOuterfilePathFromInlinePath(inlinePath); FileSystem outerFs = outerPath.getFileSystem(conf); FSDataInputStream outerStream = outerFs.open(outerPath, bufferSize); return new InLineFsDataInputStream(InLineFSUtils.startOffset(inlinePath), outerStream, InLineFSUtils.length(inlinePath)); } }
InLineFileSystem extends FileSystem { @Override public FSDataInputStream open(Path inlinePath, int bufferSize) throws IOException { Path outerPath = InLineFSUtils.getOuterfilePathFromInlinePath(inlinePath); FileSystem outerFs = outerPath.getFileSystem(conf); FSDataInputStream outerStream = outerFs.open(outerPath, bufferSize); return new InLineFsDataInputStream(InLineFSUtils.startOffset(inlinePath), outerStream, InLineFSUtils.length(inlinePath)); }  }
InLineFileSystem extends FileSystem { @Override public FSDataInputStream open(Path inlinePath, int bufferSize) throws IOException { Path outerPath = InLineFSUtils.getOuterfilePathFromInlinePath(inlinePath); FileSystem outerFs = outerPath.getFileSystem(conf); FSDataInputStream outerStream = outerFs.open(outerPath, bufferSize); return new InLineFsDataInputStream(InLineFSUtils.startOffset(inlinePath), outerStream, InLineFSUtils.length(inlinePath)); }  @Override void initialize(URI name, Configuration conf); @Override URI getUri(); String getScheme(); @Override FSDataInputStream open(Path inlinePath, int bufferSize); @Override boolean exists(Path f); @Override FileStatus getFileStatus(Path inlinePath); @Override FSDataOutputStream create(Path path, FsPermission fsPermission, boolean b, int i, short i1, long l,
                                   Progressable progressable); @Override FSDataOutputStream append(Path path, int i, Progressable progressable); @Override boolean rename(Path path, Path path1); @Override boolean delete(Path path, boolean b); @Override FileStatus[] listStatus(Path inlinePath); @Override void setWorkingDirectory(Path path); @Override Path getWorkingDirectory(); @Override boolean mkdirs(Path path, FsPermission fsPermission); }
InLineFileSystem extends FileSystem { @Override public FSDataInputStream open(Path inlinePath, int bufferSize) throws IOException { Path outerPath = InLineFSUtils.getOuterfilePathFromInlinePath(inlinePath); FileSystem outerFs = outerPath.getFileSystem(conf); FSDataInputStream outerStream = outerFs.open(outerPath, bufferSize); return new InLineFsDataInputStream(InLineFSUtils.startOffset(inlinePath), outerStream, InLineFSUtils.length(inlinePath)); }  @Override void initialize(URI name, Configuration conf); @Override URI getUri(); String getScheme(); @Override FSDataInputStream open(Path inlinePath, int bufferSize); @Override boolean exists(Path f); @Override FileStatus getFileStatus(Path inlinePath); @Override FSDataOutputStream create(Path path, FsPermission fsPermission, boolean b, int i, short i1, long l,
                                   Progressable progressable); @Override FSDataOutputStream append(Path path, int i, Progressable progressable); @Override boolean rename(Path path, Path path1); @Override boolean delete(Path path, boolean b); @Override FileStatus[] listStatus(Path inlinePath); @Override void setWorkingDirectory(Path path); @Override Path getWorkingDirectory(); @Override boolean mkdirs(Path path, FsPermission fsPermission); static final String SCHEME; }