Salah satu elemen penting dalam HDFS adalah file dan direktori, ya karena isi dari HDFS kalau ngak file dan direktori apa lagi hayo :)
berikut adalah code java untuk membuat direktori pada hadoop file system, sesuaikan dengan konfigurasi pada hadoop config pada namenode masbro masing-masing
package hery.its.tesis.bigdata.makedir;
import org.apache.hadoop.fs.*;
import org.apache.hadoop.conf.*;
public class BuatDirektori{
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);
//Buat Folder Baru di FDHS
System.out.println("Contoh Membuat Direktori");
String namaDirektori = "DirektoriBaru";
Path sumber = new Path(dfs.getWorkingDirectory()+"/"+ namaDirektori);
dfs.mkdirs(sumber);
System.out.println("Direktori "+namaDirektori+" Berhasil " + dfs.getWorkingDirectory());
}
}
yang terpenting adalah remote HDFS sesuaikann dengan port pada node master masing-masing
No comments:
Post a Comment