用Java从本地上传文件到hdfs代码
时间: 2023-02-09 11:41:14 浏览: 72
要用Java从本地上传文件到HDFS,你可以使用Hadoop的Java API。下面是一个示例代码:
```
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
public class Main {
public static void main(String[] args) throws Exception {
// 设置HDFS的配置信息
Configuration conf = new Configuration();
conf.set("fs.defaultFS", "hdfs://namenode:9000");
// 创建文件系统对象
FileSystem fs = FileSystem.get(conf);
// 本地文件路径
Path srcPath = new Path("/path/to/local/file");
// HDFS目标路径
Path dstPath = new Path("/path/to/hdfs/dst");
// 上传文件到HDFS
fs.copyFromLocalFile(srcPath, dstPath);
// 关闭文件系统
fs.close();
}
}
```
在这段代码中,我们使用了Hadoop的`Configuration`类来设置HDFS的配置信息,然后使用`FileSystem.get()`方法来获取文件系统对象。接着,我们使用`Path`类来表示本地文件路径和HDFS目标路径。最后,我们使用`FileSystem`对象的`copyFromLocalFile()`方法来上传文件到HDFS,并在最后关闭文件系统。
注意:在使用Hadoop的Java API之前,你需要在你的项目中添加Hadoop的依赖。
相关推荐
![rar](https://img-home.csdnimg.cn/images/20210720083606.png)
![rar](https://img-home.csdnimg.cn/images/20210720083606.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)