- public void testUploadFile1() throws IOException{
- Configuration conf = new Configuration();
- FileSystem fs = FileSystem.get(URI.create(hdfsUrl), conf);
- Path src = new Path("/home/xwchen/hadoop/hadoop-1.2.1/bin/rcc");
- Path dst = new Path("/test");
- fs.copyFromLocalFile(src, dst);
- }
复制代码
比如上面代码会把"/home/xwchen/hadoop/hadoop-1.2.1/bin的rcc文件上传到hdfs/test文件夹下。如果会了hdfs编程和mapreduce编程,这个不难。
可以参考:
Hadoop培训笔记之HDFS编程
hadoop实战:Java对hdfs的编程
|