从localhost在远程hdfs上创建一个目录
写了代码但不明白该写什么和在哪里写 core-site.xml 以及 hdfs-site.xml .
public class HadoopCall {
public void demomkdir(String dir) throws IOException
{
Configuration obj = new Configuration();
obj.set("fs.defaultFS", "http://datlpdsnn01.pds.in.****.com:50070/");
FileSystem fs = FileSystem.get(obj);
Path pth = new Path(dir);
fs.mkdirs(pth);
System.out.println("created");
fs.close();
}
public static void main(String[] args) throws IOException {
HadoopCall oj = new HadoopCall();
oj.demomkdir("user/*******/javacodemkdir");
}
}
1条答案
按热度按时间prdp8dxp1#
参考：hadoop配置类
如上链接所示：
core-default.xml:hadoop的只读默认值。
core-site.xml：给定hadoop安装的特定于站点的配置。
这两个文件都是特定于安装和默认配置的文件。可以使用addresource（path）方法添加上述任何xml的路径。如果没有给定路径，则从类路径变量推断xml文件路径。