欢迎投稿

今日深度:

Java连接hadoop注意事项及实例,javahadoop注意事项

Java连接hadoop注意事项及实例,javahadoop注意事项


最近正在初步学习java连接hadoop进行hdfs的简单的操作,实例代码:在hadoop的工作目录中创建某个文件,现对代码进行简单的说明:

@Test
public void testUrl(){
String dst = "hdfs://hdphost:9000/";
URI uri=URI.create(dst);
System.out.println(uri);
Configuration configuration=new Configuration();
try {
FileSystem fileSystem=FileSystem.get(uri,configuration);
FsStatus fsStatus=fileSystem.getStatus();
System.out.println(fsStatus.getUsed());
final String pathStr="/d1";
boolean flag= fileSystem.exists(new Path(pathStr));
if(!flag){
boolean result=fileSystem.mkdirs(new Path(pathStr));
System.out.println(result);
}
} catch (IOException e) {
e.printStackTrace();
}

}

导入相关jar包后,直接执行,会报错,原因hadoop的工作目录权限不足,执行hadoop fs -chmod 777 /即可。


www.htsjk.Com true http://www.htsjk.com/Hadoop/32672.html NewsArticle Java连接hadoop注意事项及实例,javahadoop注意事项 最近正在初步学习java连接hadoop进行hdfs的简单的操作,实例代码:在hadoop的工作目录中创建某个文件,现对代码进行简单的说明: @Test...
相关文章
    暂无相关文章
评论暂时关闭