全局静态变量:hdfs的地址和端口号
private static String HDFSUri = "hdfs://10.8.177.29:8020";
/**
* 获取文件系统
*
* @return FileSystem 文件系统
*/
public static FileSystem getFileSystem() {
//读取配置文件
Configuration conf = new Configuration();
// 文件系统
FileSystem fs = null;
String hdfsUri = HDFSUri;
if(StringUtils.isBlank(hdfsUri)){
// 返回默认文件系统 如果在 Hadoop集群下运行,使用此种方法可直接获取默认文件系统
try {
fs = (conf);
} catch (IOException e) {
e.printStackTrace();
}
}else{
// 返回指定的文件系统,如果在本地测试,需要使用此种方法获取文件系统
try {
URI uri = new im());
fs = (uri,conf);
} catch (Exception e) {
e.printStackTrace();
}
}
return fs;
}
入参是创建的文件目录的地址
/**
* 创建文件目录
*
* @param path 文件路径
*/
public static void m
本文发布于:2025-03-04 22:57:00,感谢您对本站的认可!
本文链接:https://www.4u4v.net/it/1741100258581298.html
版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系,我们将在24小时内删除。
留言与评论(共有 0 条评论) |