Java操作hdfs

在Java中，Hadoop Distributed File System (HDFS) 提供了一套API，使得开发者可以方便地在分布式文件系统上进行读写操作。Hadoop的HDFS客户端通常通过`java.io.FileInputStream`、`java.io.FileOutputStream`以及`org.apache.hadoop.fs.FileSystem`和`org.apache.hadoop.fs.Path`等类来操作。

以下是基本步骤：

1. **添加依赖**：首先需要在项目中引入Hadoop的HDFS库。如果你使用Maven，可以在pom.xml文件中加入`<dependency>`标签，如：

<dependency>
    <groupId>org.apache.hadoop</groupId>
    <artifactId>hadoop-client</artifactId>
    <version>3.x.x</version>
</dependency>

2. **初始化FS客户端**：

   import org.apache.hadoop.conf.Configuration;
   import org.apache.hadoop.fs.FileSystem;
   import org.apache.hadoop.fs.Path;

   Configuration conf = new Configuration();
   FileSystem fs = FileSystem.get(conf);

3. **创建路径**：

   Path filePath = new Path("/path/to/your/file");

4. **读取文件**：

   FileInputStream in = fs.open(filePath);
   // ...然后可以读取数据

5. **写入文件**：

   FileOutputStream out = fs.create(filePath);
   byte[] data = "Hello, HDFS!".getBytes();  // 数据
   out.write(data);
   out.close();

6. **关闭连接**：

   fs.close();