java - 使用 Java 将文件移动到 HDFS

Question

如何使用 Java 在 hdfs 中执行 hadoop put 文件？那可能吗？

使用这个语句:

public abstract boolean rename(Path src, Path dst) throws IOException

?

谢谢!

Answer 1

您应该能够使用 copyFromLocalFile :

Configuration conf = new Configuration();
FileSystem fs = FileSystem.get(conf);
Path localPath = new Path("path/to/local/file");
Path hdfsPath = new Path("/path/in/hdfs");
fs.copyFromLocalFile(localPath, hdfsPath);