java代码操作华为云MRS集群将TXT文件上传到HDFS目录的示例代码

在Java中，操作华为云MRS（MapReduce Service）集群并上传TXT文件到HDFS（Hadoop Distributed File System）目录通常会涉及到Hadoop的客户端API，比如`HadoopFileSystem`和`Configuration`。以下是一个简单的示例，假设已经配置了相应的Hadoop环境变量：

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

public class HdfsUploadExample {
    public static void main(String[] args) throws Exception {
        // 创建配置对象
        Configuration config = new Configuration();
        
        // 设置HDFS地址，这里需要替换为实际的MRS集群URL
        String hdfsUrl = "hdfs://<your_mrs_cluster_address>";
        config.set("fs.defaultFS", hdfsUrl);

        // 初始化Hadoop FileSystem
        FileSystem fs = FileSystem.get(config);

        // 定义源文件路径和目标HDFS路径
        String localFilePath = "/path/to/local/txt/file.txt";
        Path hdfsPath = new Path("/target/hdfs/directory/filename.txt");

        // 检查本地文件是否存在
        if (fs.exists(hdfsPath)) {
            System.out.println("File already exists in HDFS.");
        } else {
            // 如果不存在，上传文件
            fs.copyFromLocalFile(new Path(localFilePath), hdfsPath);
            System.out.println("File uploaded to HDFS successfully.");
        }

        // 关闭连接
        fs.close();
    }
}