Я пытаюсь разархивировать заархивированный каталог с несколькими файлами внутри в HDFS.
Я попробовал фрагмент кода ниже, который работает на моей локальной машине Windows:
try {
ZipFile zipFile = new ZipFile(source);
if (zipFile.isEncrypted()) {
zipFile.setPassword(password);
}
zipFile.extractAll(destination);
System.out.println("extraction successful");
} catch (ZipException e) {
e.printStackTrace();
}
где источника места назначения - путь к папке Windows.
Теперь я хочу запустить этот код, чтобы разархивировать его на hdf, означает, что источником и местом назначения должна быть HDFS, а код должен выполняться в кластере, где jar будет находиться на локальном сервере.
Может кто-нибудь помочь мне решить эту проблему?Мне нужен этот кусок кода для доступа к путям HDFS.