Hadoop HDFS分布式文件系统 HDFS

package com.itcast.hdfsdemo;

import java.io.FileNotFoundException;
import java.io.IOException;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.BlockLocation;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.LocatedFileStatus;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.fs.RemoteIterator;
import org.junit.Before;
import org.junit.Test;

public class HDFS_CRUD {
	FileSystem fs=null;
	@Before
	public  void init() throws Exception {
		
		Configuration conf=new Configuration();
		conf.set("fs.defaultFS","hdfs://192.168.121.134:9000");
		System.setProperty("HADOOP_USER_NAME","root");
		fs=FileSystem.get(conf);
	}
	@Test
   public void testAddFileToHdfs()throws IOException {
	   Path src=new Path("D:/test.txt");
	   Path dst=new Path("/testfile1");
	  //fs.copyFromLocalFile(src, dst);
	   fs.copyFromLocalFile(src, dst);
	   fs.close();
   }
	@