HDFS中FileSystem的源码分析

2019-08-05  本文已影响0人  HamletSunS

需要整理HDFS的读写过程

FileSystem设计思想

FileSystem fs = null;

    public void init() throws Exception{
        
        //读取classpath下的xxx-site.xml 配置文件,并解析其内容,封装到conf对象中
        Configuration conf = new Configuration();
        
        //也可以在代码中对conf中的配置信息进行手动设置,会覆盖掉配置文件中的读取的值
        conf.set("fs.defaultFS", "hdfs://weekend110:9000/");
        
        //根据配置信息,去获取一个具体文件系统的客户端操作实例对象
        fs = FileSystem.get(new URI("hdfs://weekend110:9000/"),conf,"hadoop");
        
        
    }

Hadoop的RPC(远程过程调用)框架实现机制

上一篇 下一篇

猜你喜欢

热点阅读