public class HDFSClientDemo {
public static void main(String[] args) throws IOException, InterruptedException {
//远程操作hadoop集群
//获取文件系统
Configuration conf = new Configuration();
//设置集群配置信息,键值对 (因为在本机上没有配置host,所以"hdfs://hadoop161:9000"无法识别,需改成要操作的机子的ip地址)
conf.set("fs.defaultFS","hdfs://192.168.12.161:9000");
//拦截本机user用户然后改成集群上的hadoop用户
System.setProperty("HADOOP_USER_NAME","hadoop");
//获取HDFS客户端对象
FileSystem fs = FileSystem.get(conf);
//在hdfs上创建目录
fs.mkdirs(new Path("/0300/abc"));
//关闭资源(释放资源)
fs.close();
//验证程序是否结束
System.out.println("over");
}
}
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 [email protected] 举报,一经查实,本站将立刻删除。