Maven:
Gradle:
providedCompile group: ‘org.apache.hadoop’, name: ‘hadoop-hdfs-client’, version: ‘3.1.4’
java 连接hdfs
import java.io.IOException;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.;
public class Application {
public static void main(String[] args) {
try {
// 配置连接地址
Configuration conf = new Configuration();
conf.set(“fs.defaultFS”, “hdfs://172.17.0.2:9000”);
FileSystem fs = FileSystem.get(conf);
// 打开文件并读取输出
Path hello = new Path(“/hello/hello.txt”);
FSDataInputStream ins = fs.open(hello);
int ch = ins.read();
while (ch != -1) {
System.out.print((char)ch);
ch = ins.read();
}
System.out.println();
} *catch (IOException ioe) {
ioe.printStackTrace();
}
}
}
