头歌HDFS-java接口之上传文件

Hadoop Distributed File System (HDFS) 是一个高度容错、高吞吐量的分布式文件系统，主要用于存储大规模数据集。在Java中操作HDFS通常通过Apache Hadoop的API，特别是`org.apache.hadoop.fs.FileSystem` 和 `org.apache.hadoop.fs.Path` 类。

如果你想通过HDFS Java接口上传文件，可以按照以下步骤操作：

1. **创建FileSystem实例**：首先，需要在程序启动时初始化一个`FileSystem`实例，这通常发生在`conf`目录下的`core-site.xml`和`hdfs-site.xml`配置文件加载后。例如：

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

2. **指定文件路径**：创建一个`Path`对象来表示你要上传的本地文件和HDFS上的目标路径，格式通常是`/your_directory/your_file_name`。

3. **检查并创建目录（如果必要）**：如果你的目标路径是一个目录，需要先检查是否已经存在，若不存在则创建它：

if (!fs.exists(targetPath)) {
    fs.mkdirs(targetPath);
}

4. **开始上传**：调用`FSDataOutputStream`来打开一个到HDFS的输出流，并使用这个流来写入文件内容：

FSDataOutputStream out = fs.create(targetPath);
FileInputStream in = new FileInputStream(localFilePath); // 本地文件
byte[] buffer = new byte[4096];
int bytesRead;
while ((bytesRead = in.read(buffer)) != -1) {
    out.write(buffer, 0, bytesRead);
}
in.close(); // 关闭本地输入流
out.close(); // 关闭HDFS输出流

5. **处理异常**：记得在整个过程中捕获可能出现的`IOException`。