使用Java API創建HDFS文件並寫入內容

package com.imooc.bigdata.hadoop.hdfs;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FSDataOutputStream;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;

import java.net.URI;

/**
 * 使用Java API操作HDFS文件系統
 *
 * 因為是放在test下面，所以最好使用單元測試的方式
 * 在pom中引入的jUnit單元測試的方式
 * 單元測試有兩個方法：（1）在單元測試之前進行；（2）在單元測試之后進行
 *
 * 關鍵點：
 * 1）創建Configuration
 * 2)獲取FileSystem
 * 3)剩下的是HDFS API的操作
 */

public class HDFSApp {

    public static final String HDFS_PATH = "hdfs://hadoop000:8020";
    //Configuration、FileSystem是每一個方法使用之前必須構建的
    Configuration configuration = null;
    FileSystem fileSystem = null;

    @Before
    public void setup() throws Exception{
        System.out.println("-----setup-----");

        configuration = new Configuration();
        /*
         *構造一個訪問指定HDFS系統的客戶端對象
         * 第一個參數：HDFS的URI
         * 第二個參數：客戶端指定的配置參數
         * 第三個參數：客戶的用戶名
         */
        fileSystem = FileSystem.get(new URI("hdfs://hadoop000:8020"), configuration, "hadoop");
    }

    /*
 * 創建HDFS文件並寫入內容 49      */
 @Test 51     public void create()throws Exception{ 52         FSDataOutputStream out = fileSystem.create(new Path("/hdfsApi/test/t.txt")); 53         out.writeUTF("hello JieQiong"); 54         out.flush();   //立即將緩沖區的數據輸出到接收方
 out.close(); 56  } 57 
    @After
    public void tearDown(){
        System.out.println("-----tearDown-----");

        //置空
        configuration = null;
        fileSystem = null;
    }
}