In einer Java-App, die auf einem Randknoten läuft, muss ich einen hdfs-Ordner löschen, falls er existiert. Ich muss das tun, bevor ich einen Mapreduce-Job (mit Spark) starte, der im Ordner ausgegeben wird.
Ich fand, ich könnte die Methode verwenden
%Vor%Ich kann jedoch nur mit einem lokalen Ordner (d. h. Datei-URL auf dem laufenden Computer) arbeiten. Ich habe versucht, etwas wie:
zu verwenden %Vor% mit hdfs://hdfshost:port ist der hdfs namenode IPC. Ich benutze es für die mapreduce, also ist es korrekt.
Es macht jedoch nichts.
Also, welche URL sollte ich verwenden, oder gibt es eine andere Methode?
Hinweis: hier ist das einfache Projekt in Frage.