（7）使用hdfs命令上传test.txt文件到HDFS的/out目录下

要在Hadoop分布式文件系统(HDFS)中使用`hdfs`命令上传文件，首先你需要确定Hadoop是否已经配置并且可用。假设你已经在当前目录/home有test.txt文件，并且HDFS的"/out"目录已经存在，你可以按照以下步骤操作：

1. 验证Hadoop CLI是否可用：

   hdfs dfs -version

2. 使用`hdfs`命令上传文件：

   hdfs dfs -put /home/test.txt /out/

这条命令的意思是将本地的"/home/test.txt"文件上传到HDFS的"/out/"路径下。

3. 验证文件是否成功上传：

   hdfs dfs -ls /out  # 查看/out目录下的文件列表，确认test.txt是否在那里

注意：在实际生产环境中，你可能需要指定全限定名（fully qualified name），即包括HDFS集群名称、主机名和路径，例如`hdfs://namenode-host:port/path`。

相关问题

使用HDFS api操作将briup.txt上传 到/user/briup/test2目录

假设你已经配置好了Hadoop的环境变量，并且启动了Hadoop集群。可以使用以下Java代码将本地文件briup.txt上传到HDFS的/user/briup/test2目录：

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import java.io.IOException;
import java.net.URI;
import java.net.URISyntaxException;

public class HDFSUploadFile {
    public static void main(String[] args) throws IOException, URISyntaxException {
        // 创建Configuration对象，用于加载Hadoop配置文件
        Configuration conf = new Configuration();
        // 指定HDFS的地址
        URI uri = new URI("hdfs://localhost:9000");
        // 创建FileSystem对象，用于操作HDFS
        FileSystem fs = FileSystem.get(uri, conf);
        // 指定本地文件路径和HDFS文件路径
        Path localPath = new Path("briup.txt");
        Path hdfsPath = new Path("/user/briup/test2/briup.txt");
        // 使用FileSystem对象将本地文件上传到HDFS
        fs.copyFromLocalFile(localPath, hdfsPath);
        // 关闭FileSystem对象
        fs.close();
        System.out.println("文件上传成功！");
    }
}

需要注意的是，上述代码中的HDFS地址是本地单机模式下的地址，如果你的Hadoop集群是分布式的，需要将HDFS地址改为集群中的地址。同时，如果/user/briup/test2目录不存在，需要先使用HDFS的Shell命令或Java API创建该目录。

hadoop hdfs api 测试代码使用HDFS Java API在HDFS的/user/hadoop目录上创建一个目录test。 在test目录中创建一个文件mytest.txt,在该文件中写入内容Hadoop is very easy to learn。 读取刚刚创建mytest.txt文件中的内容，输出文件内容并换行。

下面是使用 HDFS Java API 在 HDFS 的 /user/hadoop 目录上创建目录 test，创建文件 mytest.txt，写入内容并读取文件内容的代码：

import java.io.*;
import java.net.URI;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.*;
import org.apache.hadoop.io.IOUtils;

public class HdfsApiTest {
    private static final String HDFS_URI = "hdfs://localhost:9000";
    private static final String HDFS_USER = "hadoop";
    private static final String HDFS_DIR = "/user/hadoop/";
    private static final String HDFS_DIR_TEST = "/user/hadoop/test/";
    private static final String FILE_NAME = "mytest.txt";
    private static final String FILE_CONTENT = "Hadoop is very easy to learn.";

    public static void main(String[] args) throws IOException {
        // 获取 Hadoop 配置对象
        Configuration conf = new Configuration();
        // 设置 HDFS 用户
        conf.set("dfs.permissions.enabled", "false");
        System.setProperty("HADOOP_USER_NAME", HDFS_USER);
        // 获取 HDFS 文件系统对象
        FileSystem fs = FileSystem.get(URI.create(HDFS_URI), conf);

        // 创建目录
        Path dirPath = new Path(HDFS_DIR_TEST);
        if (!fs.exists(dirPath)) {
            fs.mkdirs(dirPath);
            System.out.println("创建目录：" + HDFS_DIR_TEST);
        }

        // 创建文件
        Path filePath = new Path(HDFS_DIR_TEST + FILE_NAME);
        if (!fs.exists(filePath)) {
            fs.createNewFile(filePath);
            System.out.println("创建文件：" + FILE_NAME);
        }

        // 写入文件内容
        FSDataOutputStream outputStream = fs.create(filePath);
        outputStream.writeBytes(FILE_CONTENT);
        outputStream.close();
        System.out.println("写入文件内容：" + FILE_CONTENT);

        // 读取文件内容
        FSDataInputStream inputStream = fs.open(filePath);
        byte[] buffer = new byte[1024];
        while (inputStream.read(buffer) > 0) {
            System.out.println(new String(buffer));
        }
        inputStream.close();

        // 关闭文件系统对象
        fs.close();
    }
}

注意：在使用 Hadoop Java API 操作 HDFS 的时候，需要设置 `HADOOP_USER_NAME` 环境变量，以指定操作 HDFS 的用户。