org.apache.hadoop.fs.Path#isUriPathAbsolute ( )源码实例Demo

public static boolean isACLsFileNewer(long time) {
  boolean newer = false;
  String confDir = System.getProperty(KMS_CONFIG_DIR);
  if (confDir != null) {
    Path confPath = new Path(confDir);
    if (!confPath.isUriPathAbsolute()) {
      throw new RuntimeException("System property '" + KMS_CONFIG_DIR +
          "' must be an absolute path: " + confDir);
    }
    File f = new File(confDir, KMS_ACLS_XML);
    // at least 100ms newer than time, we do this to ensure the file
    // has been properly closed/flushed
    newer = f.lastModified() - time > 100;
  }
  return newer;
}
 

public static boolean isACLsFileNewer(long time) {
  boolean newer = false;
  String confDir = System.getProperty(KMS_CONFIG_DIR);
  if (confDir != null) {
    Path confPath = new Path(confDir);
    if (!confPath.isUriPathAbsolute()) {
      throw new RuntimeException("System property '" + KMS_CONFIG_DIR +
          "' must be an absolute path: " + confDir);
    }
    File f = new File(confDir, KMS_ACLS_XML);
    // at least 100ms newer than time, we do this to ensure the file
    // has been properly closed/flushed
    newer = f.lastModified() - time > 100;
  }
  return newer;
}
 

public static boolean isACLsFileNewer(long time) {
  boolean newer = false;
  String confDir = System.getProperty(KMS_CONFIG_DIR);
  if (confDir != null) {
    Path confPath = new Path(confDir);
    if (!confPath.isUriPathAbsolute()) {
      throw new RuntimeException("System property '" + KMS_CONFIG_DIR +
          "' must be an absolute path: " + confDir);
    }
    File f = new File(confDir, KMS_ACLS_XML);
    // at least 100ms newer than time, we do this to ensure the file
    // has been properly closed/flushed
    newer = f.lastModified() - time > 100;
  }
  return newer;
}
 

/**
 * Return a path with the link resolved with the target.
 */
public Path getResolvedPath() throws IOException {
  // If the path is absolute we cam throw out the preceding part and
  // just append the remainder to the target, otherwise append each
  // piece to resolve the link in path.
  boolean noRemainder = (remainder == null || "".equals(remainder));
  Path target = new Path(linkTarget);
  if (target.isUriPathAbsolute()) {
    return noRemainder ? target : new Path(target, remainder);
  } else {
    return noRemainder
      ? new Path(preceding, target)
      : new Path(new Path(preceding, linkTarget), remainder);
  }
}
 

/**
 * Return a path with the link resolved with the target.
 */
public Path getResolvedPath() throws IOException {
  // If the path is absolute we cam throw out the preceding part and
  // just append the remainder to the target, otherwise append each
  // piece to resolve the link in path.
  boolean noRemainder = (remainder == null || "".equals(remainder));
  Path target = new Path(linkTarget);
  if (target.isUriPathAbsolute()) {
    return noRemainder ? target : new Path(target, remainder);
  } else {
    return noRemainder
      ? new Path(preceding, target)
      : new Path(new Path(preceding, linkTarget), remainder);
  }
}
 

public CheckpointWriteChannel create()
    throws IOException {

  final String name = namingPolicy.getNewName();
  final Path p = new Path(name);
  if (p.isUriPathAbsolute()) {
    throw new IOException("Checkpoint name cannot be an absolute path.");
  }

  return createInternal(new Path(basePath, p));
}
 

/**
 * Relative for our purposes is no scheme, no authority
 * and a non-absolute path portion.
 */
private boolean isRelative(Path path) {
  URI uri = path.toUri();
  return uri.getAuthority() == null && uri.getScheme() == null && !path.isUriPathAbsolute();
}