package hery.its.tesis.bigdata.copytolokal;
import org.apache.hadoop.fs.*;
import org.apache.hadoop.conf.*;
public class CopyHadoop2{
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);
//Salin file dari HDFS ke Local Hardisk
Path src = new Path(dfs.getWorkingDirectory()+"/a");
Path dst = new Path("/tmp/tmp/a.lokal");
dfs.copyToLocalFile(src, dst);
System.out.println("Mengkopi file HDFS "+src+" Ke "+dst);
}
}
yang terpenting adalah remote HDFS sesuaikann dengan port pada node master masing-masing
No comments:
Post a Comment