Java 类org.apache.hadoop.fs.ftp.FTPFileSystem 实例源码

项目：apex-malhar 文件：AbstractFTPInputOperator.java

@Override
protected FileSystem getFSInstance() throws IOException
{
  FTPFileSystem ftpFileSystem = new FTPFileSystem();
  String ftpUri = "ftp://" + userName + ":" + password + "@" + host + ":" + port;
  LOG.debug("ftp uri {}", ftpUri);
  ftpFileSystem.initialize(URI.create(ftpUri), configuration);
  return ftpFileSystem;
}

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

/**
 * Check the exception was about cross-directory renames
 * -if not, rethrow it.
 * @param e exception raised
 * @throws IOException
 */
private void verifyUnsupportedDirRenameException(IOException e) throws IOException {
  if (!e.toString().contains(FTPFileSystem.E_SAME_DIRECTORY_ONLY)) {
    throw e;
  }
}

项目：hadoop 文件：TestFTPContractRename.java

/**
 * Check the exception was about cross-directory renames
 * -if not, rethrow it.
 * @param e exception raised
 * @throws IOException
 */
private void verifyUnsupportedDirRenameException(IOException e) throws IOException {
  if (!e.toString().contains(FTPFileSystem.E_SAME_DIRECTORY_ONLY)) {
    throw e;
  }
}

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

/**
 * Check the exception was about cross-directory renames
 * -if not, rethrow it.
 * @param e exception raised
 * @throws IOException
 */
private void verifyUnsupportedDirRenameException(IOException e) throws IOException {
  if (!e.toString().contains(FTPFileSystem.E_SAME_DIRECTORY_ONLY)) {
    throw e;
  }
}

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

/**
 * Check the exception was about cross-directory renames
 * -if not, rethrow it.
 * @param e exception raised
 * @throws IOException
 */
private void verifyUnsupportedDirRenameException(IOException e) throws IOException {
  if (!e.toString().contains(FTPFileSystem.E_SAME_DIRECTORY_ONLY)) {
    throw e;
  }
}

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

/**
 * Check the exception was about cross-directory renames
 * -if not, rethrow it.
 * @param e exception raised
 * @throws IOException
 */
private void verifyUnsupportedDirRenameException(IOException e) throws IOException {
  if (!e.toString().contains(FTPFileSystem.E_SAME_DIRECTORY_ONLY)) {
    throw e;
  }
}

项目：hops 文件：TestFTPContractRename.java

/**
 * Check the exception was about cross-directory renames
 * -if not, rethrow it.
 * @param e exception raised
 * @throws IOException
 */
private void verifyUnsupportedDirRenameException(IOException e) throws IOException {
  if (!e.toString().contains(FTPFileSystem.E_SAME_DIRECTORY_ONLY)) {
    throw e;
  }
}