java代码调用Hadoop命令的示例代码

在Java中，调用Hadoop命令通常不是直接通过代码执行，因为Hadoop是一个批处理框架，其命令行工具（如`hadoop`, `hdfs`, `mapred`等）是为了在控制台环境中操作的。然而，如果你想要在Java应用中间接地执行Hadoop命令，你可以利用`Runtime`或`ProcessBuilder`类来执行外部命令。

以下是一个简单的例子，展示了如何使用`Runtime.getRuntime().exec()`方法来执行Hadoop命令：

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.util.Scanner;

public class HadoopCommandExecutor {
    public static void main(String[] args) {
        try {
            // 假设你想执行一个HDFS文件的复制命令
            String command = "hadoop fs -copyFromLocal source.txt /target/directory";

            // 创建一个新的进程
            Process process = Runtime.getRuntime().exec(command);

            // 获取进程的输入和输出流
            BufferedReader reader = new BufferedReader(new InputStreamReader(process.getInputStream()));
            BufferedReader errorReader = new BufferedReader(new InputStreamReader(process.getErrorStream()));

            // 读取并打印输出结果
            System.out.println("Output:");
            Scanner outputScanner = new Scanner(reader);
            while (outputScanner.hasNextLine()) {
                System.out.println(outputScanner.nextLine());
            }

            // 打印错误输出（如果有）
            if (errorReader != null) {
                System.out.println("Error Output:");
                Scanner errorScanner = new Scanner(errorReader);
                while (errorScanner.hasNextLine()) {
                    System.out.println(errorScanner.nextLine());
                }
            }

            // 等待进程完成
            int exitCode = process.waitFor();
            System.out.printf("Process exited with code %d%n", exitCode);

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

请注意，这只是一个基础示例，实际生产环境可能会有更复杂的错误处理和日志记录。同时，这个例子假设你已经在系统路径中包含了Hadoop bin目录，如果没有，需要提供完整的路径。