@Test public void getFileBlockLocations() throws IOException { final String sign = "file_blocal_locations"; FilePath fileWrite = new FilePath(new Path(folder.getRoot().toPath().toString(), sign)); writeFile(fileWrite, sign); Assert.assertEquals(1, fileWrite.getFileSystem().getFileBlockLocations( fileWrite.getFileSystem().getFileStatus(fileWrite.getPathStr()), 0, 1 ).length); }
@Override public BlockLocation[] getFileBlockLocations(FileStatus file, long start, long len) throws IOException { return load(file.getPath()).getFileBlockLocations(file, start, len); }
BaseFileSystem extends FileSystem implements WithParams<T>, Serializable { @Override public BlockLocation[] getFileBlockLocations(FileStatus file, long start, long len) throws IOException { return load(file.getPath()).getFileBlockLocations(file, start, len); } }
BaseFileSystem extends FileSystem implements WithParams<T>, Serializable { @Override public BlockLocation[] getFileBlockLocations(FileStatus file, long start, long len) throws IOException { return load(file.getPath()).getFileBlockLocations(file, start, len); } protected  BaseFileSystem(Params params); }
BaseFileSystem extends FileSystem implements WithParams<T>, Serializable { @Override public BlockLocation[] getFileBlockLocations(FileStatus file, long start, long len) throws IOException { return load(file.getPath()).getFileBlockLocations(file, start, len); } protected  BaseFileSystem(Params params); static BaseFileSystem of(Params params); static boolean isFileSystem(Params params); @Override Params getParams(); FileStatus getFileStatus(String f); FSDataInputStream open(String f, int bufferSize); FSDataInputStream open(String f); FileStatus[] listStatus(String f); boolean exists(String f); boolean delete(String f, boolean recursive); boolean mkdirs(String f); @Deprecated FSDataOutputStream create(
		String f,
		boolean overwrite,
		int bufferSize,
		short replication,
		long blockSize); @Deprecated FSDataOutputStream create(String f, boolean overwrite); FSDataOutputStream create(String f, WriteMode overwriteMode); boolean rename(String src, String dst); boolean initOutPathLocalFS(String outPath, WriteMode writeMode, boolean createDirectory); boolean initOutPathDistFS(String outPath, WriteMode writeMode, boolean createDirectory); List<String> listFiles(String f); List<String> listDirectories(String f); List<Path> listFiles(Path f); List<Path> listDirectories(Path f); abstract String getSchema(); @Override Path getWorkingDirectory(); @Override Path getHomeDirectory(); @Override URI getUri(); @Override FileStatus getFileStatus(Path f); @Override BlockLocation[] getFileBlockLocations(FileStatus file, long start, long len); @Override FSDataInputStream open(Path f, int bufferSize); @Override FSDataInputStream open(Path f); @Override FileStatus[] listStatus(Path f); @Override boolean delete(Path f, boolean recursive); @Override boolean mkdirs(Path f); @Override FSDataOutputStream create(Path f, WriteMode overwriteMode); @Override boolean rename(Path src, Path dst); @Override boolean isDistributedFS(); @Override FileSystemKind getKind(); }
BaseFileSystem extends FileSystem implements WithParams<T>, Serializable { @Override public BlockLocation[] getFileBlockLocations(FileStatus file, long start, long len) throws IOException { return load(file.getPath()).getFileBlockLocations(file, start, len); } protected  BaseFileSystem(Params params); static BaseFileSystem of(Params params); static boolean isFileSystem(Params params); @Override Params getParams(); FileStatus getFileStatus(String f); FSDataInputStream open(String f, int bufferSize); FSDataInputStream open(String f); FileStatus[] listStatus(String f); boolean exists(String f); boolean delete(String f, boolean recursive); boolean mkdirs(String f); @Deprecated FSDataOutputStream create(
		String f,
		boolean overwrite,
		int bufferSize,
		short replication,
		long blockSize); @Deprecated FSDataOutputStream create(String f, boolean overwrite); FSDataOutputStream create(String f, WriteMode overwriteMode); boolean rename(String src, String dst); boolean initOutPathLocalFS(String outPath, WriteMode writeMode, boolean createDirectory); boolean initOutPathDistFS(String outPath, WriteMode writeMode, boolean createDirectory); List<String> listFiles(String f); List<String> listDirectories(String f); List<Path> listFiles(Path f); List<Path> listDirectories(Path f); abstract String getSchema(); @Override Path getWorkingDirectory(); @Override Path getHomeDirectory(); @Override URI getUri(); @Override FileStatus getFileStatus(Path f); @Override BlockLocation[] getFileBlockLocations(FileStatus file, long start, long len); @Override FSDataInputStream open(Path f, int bufferSize); @Override FSDataInputStream open(Path f); @Override FileStatus[] listStatus(Path f); @Override boolean delete(Path f, boolean recursive); @Override boolean mkdirs(Path f); @Override FSDataOutputStream create(Path f, WriteMode overwriteMode); @Override boolean rename(Path src, Path dst); @Override boolean isDistributedFS(); @Override FileSystemKind getKind();  }