java连接hadoop集群

要连接Hadoop集群，可以使用Hadoop提供的Java API。以下是连接Hadoop集群的步骤：

1. 下载Hadoop安装包，并解压到本地。

2. 在Java代码中添加Hadoop依赖库，例如：

<dependency>
    <groupId>org.apache.hadoop</groupId>
    <artifactId>hadoop-core</artifactId>
    <version>1.2.1</version>
</dependency>

3. 在Java代码中创建一个Hadoop配置对象，设置Hadoop集群的相关配置参数，例如：

Configuration conf = new Configuration();
conf.set("fs.defaultFS", "hdfs://namenode:9000");
conf.set("mapreduce.framework.name", "yarn");
conf.set("yarn.resourcemanager.address", "resourcemanager:8032");

其中，fs.defaultFS表示HDFS的地址，mapreduce.framework.name表示MapReduce框架的类型，yarn.resourcemanager.address表示YARN资源管理器的地址。

4. 使用Hadoop的API进行操作，例如：

FileSystem fs = FileSystem.get(conf);
Path inputPath = new Path("/input");
if (fs.exists(inputPath)) {
    FileStatus[] status = fs.listStatus(inputPath);
    for (int i=0;i<status.length;i++){
        System.out.println(status[i].getPath().toString());
    }
}
fs.close();

这段代码可以获取HDFS上/input目录下的文件列表。

注意事项：在连接Hadoop集群时，需要确保Java代码所在的机器能够访问到Hadoop集群的各个节点，并且配置参数正确。