@Test public void getMountTable() throws Exception { Map<String, MountInfo> mountTable = new HashMap<>(2); mountTable.put("/mnt/foo", new MountInfo(new AlluxioURI("/mnt/foo"), new AlluxioURI("hdfs: MountContext.defaults().getOptions().build())); mountTable.put("/mnt/bar", new MountInfo(new AlluxioURI("/mnt/bar"), new AlluxioURI("hdfs: MountContext.defaults().getOptions().build())); AlluxioURI masterAddr = new AlluxioURI("alluxio: for (Map.Entry<String, MountInfo> mountPoint : mountTable.entrySet()) { MountInfo mountInfo = mountPoint.getValue(); mMountTable.add(NoopJournalContext.INSTANCE, masterAddr.join(mountPoint.getKey()), mountInfo.getUfsUri(), mountInfo.getMountId(), mountInfo.getOptions()); } mountTable.put("/", new MountInfo(new AlluxioURI("/"), new AlluxioURI("s3a: IdUtils.ROOT_MOUNT_ID, MountContext.defaults().getOptions().build())); Assert.assertEquals(mountTable, mMountTable.getMountTable()); }
public Map<String, MountInfo> getMountTable() { try (LockResource r = new LockResource(mReadLock)) { return new HashMap<>(mState.getMountTable()); } }
MountTable implements DelegatingJournaled { public Map<String, MountInfo> getMountTable() { try (LockResource r = new LockResource(mReadLock)) { return new HashMap<>(mState.getMountTable()); } } }
MountTable implements DelegatingJournaled { public Map<String, MountInfo> getMountTable() { try (LockResource r = new LockResource(mReadLock)) { return new HashMap<>(mState.getMountTable()); } } MountTable(UfsManager ufsManager, MountInfo rootMountInfo); }
MountTable implements DelegatingJournaled { public Map<String, MountInfo> getMountTable() { try (LockResource r = new LockResource(mReadLock)) { return new HashMap<>(mState.getMountTable()); } } MountTable(UfsManager ufsManager, MountInfo rootMountInfo); void add(Supplier<JournalContext> journalContext, AlluxioURI alluxioUri, AlluxioURI ufsUri,
      long mountId, MountPOptions options); boolean delete(Supplier<JournalContext> journalContext, AlluxioURI uri,
      boolean checkNestedMount); void update(Supplier<JournalContext> journalContext, AlluxioURI alluxioUri,
      long newMountId, MountPOptions newOptions); String getMountPoint(AlluxioURI uri); Map<String, MountInfo> getMountTable(); boolean containsMountPoint(AlluxioURI uri, boolean containsSelf); boolean isMountPoint(AlluxioURI uri); @Nullable ReverseResolution reverseResolve(AlluxioURI ufsUri); @Nullable UfsManager.UfsClient getUfsClient(long mountId); Resolution resolve(AlluxioURI uri); void checkUnderWritableMountPoint(AlluxioURI alluxioUri); @Nullable MountInfo getMountInfo(long mountId); @Override Journaled getDelegate(); }
MountTable implements DelegatingJournaled { public Map<String, MountInfo> getMountTable() { try (LockResource r = new LockResource(mReadLock)) { return new HashMap<>(mState.getMountTable()); } } MountTable(UfsManager ufsManager, MountInfo rootMountInfo); void add(Supplier<JournalContext> journalContext, AlluxioURI alluxioUri, AlluxioURI ufsUri,
      long mountId, MountPOptions options); boolean delete(Supplier<JournalContext> journalContext, AlluxioURI uri,
      boolean checkNestedMount); void update(Supplier<JournalContext> journalContext, AlluxioURI alluxioUri,
      long newMountId, MountPOptions newOptions); String getMountPoint(AlluxioURI uri); Map<String, MountInfo> getMountTable(); boolean containsMountPoint(AlluxioURI uri, boolean containsSelf); boolean isMountPoint(AlluxioURI uri); @Nullable ReverseResolution reverseResolve(AlluxioURI ufsUri); @Nullable UfsManager.UfsClient getUfsClient(long mountId); Resolution resolve(AlluxioURI uri); void checkUnderWritableMountPoint(AlluxioURI alluxioUri); @Nullable MountInfo getMountInfo(long mountId); @Override Journaled getDelegate(); static final String ROOT; }