【hadoop 2.6.0】Hadoopを利用したJava API

Hadoop2.6.0のすべてのJava APIはhttp://hadoop.apache.org/docs/r2.6.0/api/overview-summary.htmlにあります.
次に、Java APIを用いてHDFSファイルを作成する例を実装する.『実践Hadoop』(劉鵬)の50ページを参照.
 
FileSystemを利用する.create(Path f)実装
最初のステップはjavaコードを書き、MyCreateFileと名付けます.JAva注意hadoopのルートディレクトリの下に必ず置く

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FSDataOutputStream;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
public class MyCreateFile{
        public static void main(String[] args)throws Exception{
                Configuration conf=new Configuration();
                byte[] buff="hello wordl!".getBytes();
                FileSystem hdfs=FileSystem.get(conf);
                Path dfs=new Path("/user/kzy/new_file");
                FSDataOutputStream outputStream=hdfs.create(dfs);
                outputStream.write(buff,0,buff.length);
        }
}

 
第2のステップでは、コンパイルパッケージは、コマンドラインに次の2つのコマンドを入力し、mcfにパッケージする.jar

bin/hadoop com.sun.tools.javac.Main MyCreateFile.java 
jar cf mcf.jar MyCreateFile*.class

 
ステップ3で、コマンドラインへの入力を実行します.

bin/hadoop jar mcf.jar MyCreateFile

 
に着くhttp://localhost:50070で表示された結果、/user/kzyディレクトリの下に新しいファイルnew_が表示されました.file