Java 类org.apache.hadoop.fs.BlockStoragePolicySpi 实例源码

@Override
public BlockStoragePolicySpi getStoragePolicy(final Path src)
    throws IOException {
  return myFs.getStoragePolicy(src);
}

@Override
public Collection<? extends BlockStoragePolicySpi> getAllStoragePolicies()
    throws IOException {
  return myFs.getAllStoragePolicies();
}

@Override
public BlockStoragePolicySpi getStoragePolicy(final Path src)
    throws IOException {
  return myFs.getStoragePolicy(src);
}

@Override
public Collection<? extends BlockStoragePolicySpi> getAllStoragePolicies()
    throws IOException {
  return myFs.getAllStoragePolicies();
}

@Override
public BlockStoragePolicySpi getStoragePolicy(final Path src)
    throws IOException {
  return myFs.getStoragePolicy(src);
}

@Override
public Collection<? extends BlockStoragePolicySpi> getAllStoragePolicies()
    throws IOException {
  return myFs.getAllStoragePolicies();
}

/**
 * Retrieve the storage policy for a given file or directory.
 *
 * @param src file or directory path.
 * @return storage policy for give file.
 * @throws IOException
 */
public BlockStoragePolicySpi getStoragePolicy(final Path src)
    throws IOException {
  InodeTree.ResolveResult<AbstractFileSystem> res =
      fsState.resolve(getUriPath(src), true);
  return res.targetFileSystem.getStoragePolicy(res.remainingPath);
}

/**
 * Retrieve the storage policy for a given file or directory.
 *
 * @param src file or directory path.
 * @return storage policy for give file.
 * @throws IOException
 */
public BlockStoragePolicySpi getStoragePolicy(final Path src)
    throws IOException {
  InodeTree.ResolveResult<AbstractFileSystem> res =
      fsState.resolve(getUriPath(src), true);
  return res.targetFileSystem.getStoragePolicy(res.remainingPath);
}

/**
 * Retrieve the storage policy for a given file or directory.
 *
 * @param src file or directory path.
 * @return storage policy for give file.
 * @throws IOException
 */
public BlockStoragePolicySpi getStoragePolicy(final Path src)
    throws IOException {
  InodeTree.ResolveResult<AbstractFileSystem> res =
      fsState.resolve(getUriPath(src), true);
  return res.targetFileSystem.getStoragePolicy(res.remainingPath);
}