import org.apache.hadoop.fs.ftp.FTPFileSystem; //导入依赖的package包/类
@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;
}
 

import org.apache.hadoop.fs.ftp.FTPFileSystem; //导入依赖的package包/类
/**
 * 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;
  }
}