package hery.its.tesis.bigdata.deldir;
import org.apache.hadoop.fs.*;
import org.apache.hadoop.conf.*;
public class HapusDirektori{
public static void main (String [] args) throws Exception
{
//Membuat Koneksi ke HDFS
Configuration konfigurasi = new Configuration();
konfigurasi.set("fs.default.name","hdfs://master:54310/");
FileSystem dfs = FileSystem.get(konfigurasi);
//Hapus Direktori/File di FDHS
String dirName = "sip";
Path src = new Path(dfs.getWorkingDirectory()+"/"+dirName);
dfs.delete(src);
System.out.println("Contoh Menghapus File "+src+dirName);
}
}
yang terpenting adalah remote HDFS sesuaikann dengan port pada node master masing-masing
No comments:
Post a Comment