编写程序将linux上的文件上传到hdfs系统,程序如下:

URI arg0=new URI("hdfs://localhost:9000");
Configuration arg1=new Configuration();
FileSystem  hdfs=FileSystem.get(arg0, arg1);
Path src=new Path("/home/a.py");
Path dst=new Path("/usr/newfile");
hdfs.copyFromLocalFile(src, dst);
System.out.println("End");

将hdfs系统上的文件下载到linux系统的代码与上述是类似的,不过使用的函数是:copyToLocalFile。

0
Posted in BigData

Leave a Comment:

电子邮件地址不会被公开。