4.文件写入

// 写入文件
import org.apache.hadoop.conf.Configuration;  
import org.apache.hadoop.fs.FileSystem; //用于创建文件系统实例，用FileSystem.create方法可以打开一个输出流，返回FSDataOutputStream
import org.apache.hadoop.fs.FSDataOutputStream; 
import org.apache.hadoop.fs.Path; // 用于创建和解决文件路径，且FileSystem的方法大部分要求必须传入Path对象
public class WriteFIle {    
        public static void main(String[] args) { 
                try {
                        Configuration conf = new Configuration();  
                        conf.set("fs.defaultFS","hdfs://localhost:9000");
                        conf.set("fs.hdfs.impl","org.apache.hadoop.hdfs.DistributedFileSystem");
                        FileSystem fs = FileSystem.get(conf);
                        byte[] buff = "Hello world".getBytes(); // 要写入的内容
                        String filename = "writein"; //要写入的文件名
                        FSDataOutputStream os = fs.create(new Path(filename)); //FS.create和open类似，用于打开一个输出流，并返回一个输出流对象
                        os.write(buff,0,buff.length);
                        System.out.println("Create:"+ filename);
                        os.close();
                        fs.close();
                } catch (Exception e) {  
                        e.printStackTrace();  
                }  
        }  
}