读文件:通过“ReadUTF()”方法可以实现对指定文件进行读操作。
具体代码如下:``` package HDFS.learnself;
import java.io.IOException; import java.net.URI; import java.net.URISyntaxException; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FSDataInputStream; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path;
public class Read { public static void main(String[] args) throws IOException, InterruptedException, URISyntaxException {
//1.加载hdfs的配置文件 Configuration conf=new Configuration();
//2.获取hdfs的操作对象 FileSystem fs=FileSystem.get(new URI("hdfs://hdp01:9000"), conf, "hdp02");
//3.读取文件的路径 Path File=new Path("hdfs://hdp01:9000/test/cao.txt");
//4.创建FSDataInputStream对象 FSDataInputStream in=fs.open(File); String info = in.readUTF();
System.out.println("数据读取成功!"); System.out.println(info); in.close(); } }
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。