package hery.its.tesis.bigdata.ls;
import org.apache.hadoop.fs.*;
import org.apache.hadoop.conf.*;
public class liatDirektori{
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);
//list direktori HDFS
FileStatus[] status = dfs.listStatus(new Path("/user/hduser/"));
for(int i=0;i<status.length;i++)
{
System.out.println(status[i].getPath());
}
}
}
yang terpenting adalah remote HDFS sesuaikann dengan port pada node master masing-masing
No comments:
Post a Comment