java测试连接hadoop的代码
时间: 2023-07-11 13:52:51 浏览: 134
您好,以下是一个简单的Java代码示例,用于测试连接Hadoop集群:
```java
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
public class HdfsConnectionTest {
public static void main(String[] args) throws Exception {
Configuration conf = new Configuration();
conf.set("fs.defaultFS", "hdfs://localhost:9000");
FileSystem fs = FileSystem.get(conf);
Path homeDir = fs.getHomeDirectory();
System.out.println("Hadoop home directory: " + homeDir.toString());
fs.close();
}
}
```
上面的代码示例使用了Hadoop的Java API,首先设置了Hadoop集群的地址,然后通过FileSystem类获取Hadoop的文件系统对象。接下来,使用getHomeDirectory方法获取Hadoop的主目录,并输出该目录的路径。
请注意,您需要将代码中的fs.defaultFS替换为您自己的Hadoop集群地址。
希望这可以帮助您测试连接Hadoop集群!
阅读全文