向集群传文件
package hdfs;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.junit.Test;
public class HDFSAPI {
@Test
public void testHdfsConn() throws Exception {
Configuration conf = new Configuration();
//FileSystem fs = FileSystem.get(new URI("hdfs://node101:9000"), conf, "bduser101");
FileSystem fs = FileSystem.get(conf);
System.out.println(fs);
fs.copyFromLocalFile(new Path("file:///E:/study/2020BigData/CentOS-6.5-x86_64-bin-DVD1to2/CentOS-6.5-x86_64-bin-DVD1to2/4D0F5C9F9E606BCB1808BB33E36794DB9E8407E3.torrent"), new Path("hdfs://node101:9000/animal/tager/test11.txt"));
/* Configuration conf = new Configuration();
FileSystem fs = FileSystem.get(new URI("hdfs://aliyun:9000"), conf, "bduser");
//FileSystem fs = FileSystem.get(conf);
System.out.println(fs);
fs.copyFromLocalFile(new Path("file:///E:/study/2020BigData/CentOS-6.5-x86_64-bin-DVD1to2/CentOS-6.5-x86_64-bin-DVD1to2/4D0F5C9F9E606BCB1808BB33E36794DB9E8407E3.torrent"), new Path("hdfs://aliyun:9000/animals/tiger/test8.txt"));
*/
fs.close();
}
}