mapreduce项目上传文件到hdfs代码

### 回答1：
要将文件上传到 HDFS，您需要使用 Hadoop 的 `FileSystem` 类中的 `copyFromLocalFile` 方法。这是一个示例代码，假设您已经安装了 Hadoop 并正确配置了环境变量：

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

public class HDFSUploader {

  public static void main(String[] args) throws Exception {
    // 创建 Configuration 对象
    Configuration conf = new Configuration();
    // 获取文件系统
    FileSystem fs = FileSystem.get(conf);
    // 要上传的文件的本地路径
    Path srcPath = new Path("/path/to/local/file.txt");
    // HDFS 上的目标路径
    Path dstPath = new Path("/path/to/hdfs/destination/file.txt");
    // 将文件上传到 HDFS
    fs.copyFromLocalFile(srcPath, dstPath);
    // 关闭文件系统
    fs.close();
  }

}

在这个示例中，我们创建了一个 `Configuration` 对象，然后使用它获取了 Hadoop 的文件系统。然后，我们使用 `copyFromLocalFile` 方法将本地文件上传到 HDFS。最后，我们记得关闭文件系统。

请注意，在这个示例中，我们假设您已经正确配置了 Hadoop 的环境变量。如果您还没有安装 Hadoop 或配置环境变量，则需要在代码中指定 Hadoop 的安装路径。

希望这个示例对您有所帮助。

### 回答2：
要将文件上传到HDFS的MapReduce项目中，需要编写以下代码：

1. 构建Configuration对象并设置Hadoop集群的相关配置属性：

Configuration conf = new Configuration();
conf.set("fs.defaultFS", "hdfs://localhost:9000");
conf.set("dfs.replication", "1"); // 设置文件副本数

2. 创建一个Job对象并配置相关属性：

Job job = Job.getInstance(conf, "UploadFileToHDFS");
job.setJarByClass(UploadFileToHDFS.class);

// 设置Mapper
job.setMapperClass(UploadFileMapper.class);
job.setInputFormatClass(TextInputFormat.class);
TextInputFormat.addInputPath(job, new Path("input_file_path"));

// 设置Reducer
job.setNumReduceTasks(0); // 不需要Reducer

// 设置输出格式
job.setOutputKeyClass(Text.class);
job.setOutputValueClass(NullWritable.class);
job.setOutputFormatClass(NullOutputFormat.class);

// 设置输出目录
FileOutputFormat.setOutputPath(job, new Path("hdfs://localhost:9000/output_path"));

3. 编写Mapper类，实现文件上传逻辑：

public static class UploadFileMapper extends Mapper<LongWritable, Text, Text, NullWritable> {
    public void map(LongWritable key, Text value, Context context) throws IOException, InterruptedException {
        Configuration conf = context.getConfiguration();
        FileSystem fs = FileSystem.get(conf);

        String localFilePath = value.toString();
        Path srcPath = new Path(localFilePath);
        Path dstPath = new Path("hdfs://localhost:9000/output_path/" + srcPath.getName());

        fs.copyFromLocalFile(srcPath, dstPath); // 上传文件到HDFS

        context.write(new Text("File " + srcPath.getName() + " uploaded successfully."), NullWritable.get());
    }
}

4. 最后，执行MapReduce任务：

System.exit(job.waitForCompletion(true) ? 0 : 1);

以上代码中，需要将`input_file_path`替换为要上传的文件在本地的路径，`output_path`替换为上传到HDFS的目标路径。

### 回答3：
上传文件到HDFS的代码可以使用Hadoop的Java API来实现。以下是一个简单的示例代码：

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.*;

public class FileUploader {
    public static void main(String[] args) {
        String localFilePath = "example.txt";
        String hdfsFilePath = "/user/test/example.txt";

        Configuration conf = new Configuration();
        conf.set("fs.defaultFS", "hdfs://localhost:9000");

        try {
            FileSystem fs = FileSystem.get(conf);
            Path srcPath = new Path(localFilePath);
            Path destPath = new Path(hdfsFilePath);

            fs.copyFromLocalFile(srcPath, destPath);

            System.out.println("文件上传成功！");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

在这个示例中，我们首先指定了本地文件的路径和HDFS中的路径。然后，我们创建了一个Hadoop的Configuration对象，并设置了HDFS的地址。

接下来，我们通过调用`FileSystem.get(conf)`获取一个FileSystem对象，然后使用`copyFromLocalFile`方法将本地文件上传到HDFS中的指定路径。

最后，我们会打印出"文件上传成功！"的消息来提示文件上传操作已完成。

需要注意的是，此代码需要在安装了Hadoop或者能够访问Hadoop集群的机器上运行。另外，还需要将本地文件的路径和HDFS路径进行相应修改，以适应你的实际需求。