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

项目：hadoop-oss 文件：CommandWithDestination.java

/**
 * Called with a source and target destination pair
 * @param src for the operation
 * @param dst for the operation
 * @throws IOException if anything goes wrong
 */
protected void processPath(PathData src, PathData dst) throws IOException {
  if (src.stat.isSymlink()) {
    // TODO: remove when FileContext is supported, this needs to either
    // copy the symlink or deref the symlink
    throw new PathOperationException(src.toString());        
  } else if (src.stat.isFile()) {
    copyFileToTarget(src, dst);
  } else if (src.stat.isDirectory() && !isRecursive()) {
    throw new PathIsDirectoryException(src.toString());
  }
}

项目：hadoop 文件：CommandWithDestination.java

/**
 * Called with a source and target destination pair
 * @param src for the operation
 * @param dst for the operation
 * @throws IOException if anything goes wrong
 */
protected void processPath(PathData src, PathData dst) throws IOException {
  if (src.stat.isSymlink()) {
    // TODO: remove when FileContext is supported, this needs to either
    // copy the symlink or deref the symlink
    throw new PathOperationException(src.toString());        
  } else if (src.stat.isFile()) {
    copyFileToTarget(src, dst);
  } else if (src.stat.isDirectory() && !isRecursive()) {
    throw new PathIsDirectoryException(src.toString());
  }
}

项目：aliyun-oss-hadoop-fs 文件：CommandWithDestination.java

/**
 * Called with a source and target destination pair
 * @param src for the operation
 * @param dst for the operation
 * @throws IOException if anything goes wrong
 */
protected void processPath(PathData src, PathData dst) throws IOException {
  if (src.stat.isSymlink()) {
    // TODO: remove when FileContext is supported, this needs to either
    // copy the symlink or deref the symlink
    throw new PathOperationException(src.toString());        
  } else if (src.stat.isFile()) {
    copyFileToTarget(src, dst);
  } else if (src.stat.isDirectory() && !isRecursive()) {
    throw new PathIsDirectoryException(src.toString());
  }
}

项目：big-c 文件：CommandWithDestination.java

/**
 * Called with a source and target destination pair
 * @param src for the operation
 * @param dst for the operation
 * @throws IOException if anything goes wrong
 */
protected void processPath(PathData src, PathData dst) throws IOException {
  if (src.stat.isSymlink()) {
    // TODO: remove when FileContext is supported, this needs to either
    // copy the symlink or deref the symlink
    throw new PathOperationException(src.toString());        
  } else if (src.stat.isFile()) {
    copyFileToTarget(src, dst);
  } else if (src.stat.isDirectory() && !isRecursive()) {
    throw new PathIsDirectoryException(src.toString());
  }
}

项目：hadoop-2.6.0-cdh5.4.3 文件：CommandWithDestination.java

/**
 * Called with a source and target destination pair
 * @param src for the operation
 * @param dst for the operation
 * @throws IOException if anything goes wrong
 */
protected void processPath(PathData src, PathData dst) throws IOException {
  if (src.stat.isSymlink()) {
    // TODO: remove when FileContext is supported, this needs to either
    // copy the symlink or deref the symlink
    throw new PathOperationException(src.toString());        
  } else if (src.stat.isFile()) {
    copyFileToTarget(src, dst);
  } else if (src.stat.isDirectory() && !isRecursive()) {
    throw new PathIsDirectoryException(src.toString());
  }
}

项目：hadoop-plus 文件：CommandWithDestination.java

/**
 * Called with a source and target destination pair
 * @param src for the operation
 * @param target for the operation
 * @throws IOException if anything goes wrong
 */
protected void processPath(PathData src, PathData dst) throws IOException {
  if (src.stat.isSymlink()) {
    // TODO: remove when FileContext is supported, this needs to either
    // copy the symlink or deref the symlink
    throw new PathOperationException(src.toString());        
  } else if (src.stat.isFile()) {
    copyFileToTarget(src, dst);
  } else if (src.stat.isDirectory() && !isRecursive()) {
    throw new PathIsDirectoryException(src.toString());
  }
}

项目：hops 文件：CommandWithDestination.java

/**
 * Called with a source and target destination pair
 * @param src for the operation
 * @param dst for the operation
 * @throws IOException if anything goes wrong
 */
protected void processPath(PathData src, PathData dst) throws IOException {
  if (src.stat.isSymlink()) {
    // TODO: remove when FileContext is supported, this needs to either
    // copy the symlink or deref the symlink
    throw new PathOperationException(src.toString());        
  } else if (src.stat.isFile()) {
    copyFileToTarget(src, dst);
  } else if (src.stat.isDirectory() && !isRecursive()) {
    throw new PathIsDirectoryException(src.toString());
  }
}

项目：hadoop-TCP 文件：CommandWithDestination.java

/**
 * Called with a source and target destination pair
 * @param src for the operation
 * @param target for the operation
 * @throws IOException if anything goes wrong
 */
protected void processPath(PathData src, PathData dst) throws IOException {
  if (src.stat.isSymlink()) {
    // TODO: remove when FileContext is supported, this needs to either
    // copy the symlink or deref the symlink
    throw new PathOperationException(src.toString());        
  } else if (src.stat.isFile()) {
    copyFileToTarget(src, dst);
  } else if (src.stat.isDirectory() && !isRecursive()) {
    throw new PathIsDirectoryException(src.toString());
  }
}

项目：hardfs 文件：CommandWithDestination.java

/**
 * Called with a source and target destination pair
 * @param src for the operation
 * @param target for the operation
 * @throws IOException if anything goes wrong
 */
protected void processPath(PathData src, PathData dst) throws IOException {
  if (src.stat.isSymlink()) {
    // TODO: remove when FileContext is supported, this needs to either
    // copy the symlink or deref the symlink
    throw new PathOperationException(src.toString());        
  } else if (src.stat.isFile()) {
    copyFileToTarget(src, dst);
  } else if (src.stat.isDirectory() && !isRecursive()) {
    throw new PathIsDirectoryException(src.toString());
  }
}

项目：hadoop-on-lustre2 文件：CommandWithDestination.java

/**
 * Called with a source and target destination pair
 * @param src for the operation
 * @param target for the operation
 * @throws IOException if anything goes wrong
 */
protected void processPath(PathData src, PathData dst) throws IOException {
  if (src.stat.isSymlink()) {
    // TODO: remove when FileContext is supported, this needs to either
    // copy the symlink or deref the symlink
    throw new PathOperationException(src.toString());        
  } else if (src.stat.isFile()) {
    copyFileToTarget(src, dst);
  } else if (src.stat.isDirectory() && !isRecursive()) {
    throw new PathIsDirectoryException(src.toString());
  }
}