@Test public void mount() throws Exception { FileSystem fileSystem = new DelegatingFileSystem(mMockFileSystem); AlluxioURI alluxioPath = new AlluxioURI("/t"); AlluxioURI ufsPath = new AlluxioURI("/u"); MountPOptions mountOptions = MountPOptions .newBuilder() .setReadOnly(false) .setShared(false) .build(); fileSystem.mount(alluxioPath, ufsPath, mountOptions); Mockito.verify(mMockFileSystem, atLeastOnce()) .mount(eq(alluxioPath), eq(ufsPath), eq(mountOptions)); }
@Override public void mount(AlluxioURI alluxioPath, AlluxioURI ufsPath, MountPOptions options) throws IOException, AlluxioException { mDelegatedFileSystem.mount(alluxioPath, ufsPath, options); }
DelegatingFileSystem implements FileSystem { @Override public void mount(AlluxioURI alluxioPath, AlluxioURI ufsPath, MountPOptions options) throws IOException, AlluxioException { mDelegatedFileSystem.mount(alluxioPath, ufsPath, options); } }
DelegatingFileSystem implements FileSystem { @Override public void mount(AlluxioURI alluxioPath, AlluxioURI ufsPath, MountPOptions options) throws IOException, AlluxioException { mDelegatedFileSystem.mount(alluxioPath, ufsPath, options); } DelegatingFileSystem(FileSystem fs); }
DelegatingFileSystem implements FileSystem { @Override public void mount(AlluxioURI alluxioPath, AlluxioURI ufsPath, MountPOptions options) throws IOException, AlluxioException { mDelegatedFileSystem.mount(alluxioPath, ufsPath, options); } DelegatingFileSystem(FileSystem fs); @Override boolean isClosed(); @Override void createDirectory(AlluxioURI path, CreateDirectoryPOptions options); @Override FileOutStream createFile(AlluxioURI path, CreateFilePOptions options); @Override void delete(AlluxioURI path, DeletePOptions options); @Override boolean exists(AlluxioURI path, ExistsPOptions options); @Override void free(AlluxioURI path, FreePOptions options); @Override List<BlockLocationInfo> getBlockLocations(AlluxioURI path); @Override AlluxioConfiguration getConf(); @Override URIStatus getStatus(AlluxioURI path, GetStatusPOptions options); @Override List<URIStatus> listStatus(AlluxioURI path, ListStatusPOptions options); @Override void mount(AlluxioURI alluxioPath, AlluxioURI ufsPath, MountPOptions options); @Override void updateMount(AlluxioURI alluxioPath, MountPOptions options); @Override Map<String, MountPointInfo> getMountTable(); @Override List<SyncPointInfo> getSyncPathList(); @Override FileInStream openFile(AlluxioURI path, OpenFilePOptions options); @Override FileInStream openFile(URIStatus status, OpenFilePOptions options); @Override void persist(AlluxioURI path, ScheduleAsyncPersistencePOptions options); @Override void rename(AlluxioURI src, AlluxioURI dst, RenamePOptions options); @Override AlluxioURI reverseResolve(AlluxioURI ufsUri); @Override void setAcl(AlluxioURI path, SetAclAction action, List<AclEntry> entries,
      SetAclPOptions options); @Override void startSync(AlluxioURI path); @Override void stopSync(AlluxioURI path); @Override void setAttribute(AlluxioURI path, SetAttributePOptions options); @Override void unmount(AlluxioURI path, UnmountPOptions options); @Override void close(); }
DelegatingFileSystem implements FileSystem { @Override public void mount(AlluxioURI alluxioPath, AlluxioURI ufsPath, MountPOptions options) throws IOException, AlluxioException { mDelegatedFileSystem.mount(alluxioPath, ufsPath, options); } DelegatingFileSystem(FileSystem fs); @Override boolean isClosed(); @Override void createDirectory(AlluxioURI path, CreateDirectoryPOptions options); @Override FileOutStream createFile(AlluxioURI path, CreateFilePOptions options); @Override void delete(AlluxioURI path, DeletePOptions options); @Override boolean exists(AlluxioURI path, ExistsPOptions options); @Override void free(AlluxioURI path, FreePOptions options); @Override List<BlockLocationInfo> getBlockLocations(AlluxioURI path); @Override AlluxioConfiguration getConf(); @Override URIStatus getStatus(AlluxioURI path, GetStatusPOptions options); @Override List<URIStatus> listStatus(AlluxioURI path, ListStatusPOptions options); @Override void mount(AlluxioURI alluxioPath, AlluxioURI ufsPath, MountPOptions options); @Override void updateMount(AlluxioURI alluxioPath, MountPOptions options); @Override Map<String, MountPointInfo> getMountTable(); @Override List<SyncPointInfo> getSyncPathList(); @Override FileInStream openFile(AlluxioURI path, OpenFilePOptions options); @Override FileInStream openFile(URIStatus status, OpenFilePOptions options); @Override void persist(AlluxioURI path, ScheduleAsyncPersistencePOptions options); @Override void rename(AlluxioURI src, AlluxioURI dst, RenamePOptions options); @Override AlluxioURI reverseResolve(AlluxioURI ufsUri); @Override void setAcl(AlluxioURI path, SetAclAction action, List<AclEntry> entries,
      SetAclPOptions options); @Override void startSync(AlluxioURI path); @Override void stopSync(AlluxioURI path); @Override void setAttribute(AlluxioURI path, SetAttributePOptions options); @Override void unmount(AlluxioURI path, UnmountPOptions options); @Override void close();  }