Q:
W: GPG error: http://ppa.launchpad.net intrepid Release: 由於沒有公鑰，下列簽名無法進行驗證： NO_PUBKEY 60D11217247D1CFF
A:
sudo apt-key adv --recv-keys --keyserver keyserver.ubuntu.com 60D11217247D1CFF
2009年3月16日 星期一
2009年2月17日 星期二
Read HDFS File
FileSystem fs=FileSystem.get(new URI("hdfs://localhost:9000"),new Configuration());
FileStatus[] flist=fs.listStatus(new Path("input/"));
FSDataInputStream fsdatainput=fs.open(flist[0].getPath());
BufferedReader bfr=new BufferedReader(new InputStreamReader(fsdatainput));
while(bfr.ready())
{
System.out.println(bfr.readLine());
}
直接讀取比較省事!!
FileStatus[] flist=fs.listStatus(new Path("input/"));
FSDataInputStream fsdatainput=fs.open(flist[0].getPath());
BufferedReader bfr=new BufferedReader(new InputStreamReader(fsdatainput));
while(bfr.ready())
{
System.out.println(bfr.readLine());
}
直接讀取比較省事!!
2009年2月10日 星期二
hadoop FileSystem
最近又要開始接觸hadoop了，為了把資料在程式裡直接上傳到HDFS裡，努力嘗試找了非常久的api。終於找到了FileSystem！暫時順利的將資料傳到HDFS。
FileSystem uptohdfs = FileSystem.get(new Path("hdfs://localhost:9000"),
new Configuration());
uptohdfs.copyFromLocalFile(Path src, Path dst) ;
上傳成功，要記得執行的使用者有寫入的權限!!
FileSystem uptohdfs = FileSystem.get(new Path("hdfs://localhost:9000"),
new Configuration());
uptohdfs.copyFromLocalFile(Path src, Path dst) ;
上傳成功，要記得執行的使用者有寫入的權限!!
訂閱：
文章 (Atom)