使用 Java API 在 HDFS 上创建文件并写入内容在 /user/hadoop/test 目录下创建一个文件 mytest.txt,在该文件中写入如下内容: Hadoop is very easy to learn
时间: 2024-05-05 14:20:07 浏览: 270
Hadoop快速入门
5星 · 资源好评率100%
好的,下面是 Java 代码实现:
```java
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.fs.FSDataOutputStream;
public class HdfsTest {
public static void main(String[] args) throws Exception {
// 创建Hadoop配置对象
Configuration conf = new Configuration();
// 设置HDFS的访问地址
conf.set("fs.defaultFS", "hdfs://localhost:9000");
// 获取HDFS文件系统对象
FileSystem fs = FileSystem.get(conf);
// 创建文件路径
Path filePath = new Path("/user/hadoop/test/mytest.txt");
// 创建文件输出流
FSDataOutputStream outputStream = fs.create(filePath);
// 往文件中写入内容
String content = "Hadoop is very easy to learn";
outputStream.write(content.getBytes("UTF-8"));
// 关闭文件输出流
outputStream.close();
// 关闭文件系统对象
fs.close();
System.out.println("文件创建成功!");
}
}
```
这段代码通过 Hadoop 的 Java API 创建了一个 HDFS 文件系统对象,然后在指定目录下创建了一个 mytest.txt 文件,并向其中写入了指定的内容。最后关闭文件系统对象,释放资源。
阅读全文