zoukankan      html  css  js  c++  java
  • Java API操作HA方式下的Hadoop

    通过java api连接Hadoop集群时,如果集群支持HA方式,那么可以通过如下方式设置来自动切换到活动的master节点上。其中,ClusterName 是可以任意指定的,跟集群配置无关,dfs.ha.namenodes.ClusterName也可以任意指定名称,有几个master就写几个,后面根据相应的设置添加master节点地址即可。

    private static String ClusterName = "nsstargate";
        private static final String HADOOP_URL = "hdfs://"+ClusterName;
        public static Configuration conf;
    
        static {
            conf = new Configuration();
            conf.set("fs.defaultFS", HADOOP_URL);
            conf.set("dfs.nameservices", ClusterName);
            conf.set("dfs.ha.namenodes."+ClusterName, "nn1,nn2");
            conf.set("dfs.namenode.rpc-address."+ClusterName+".nn1", "172.16.50.24:8020");
            conf.set("dfs.namenode.rpc-address."+ClusterName+".nn2", "172.16.50.21:8020");
            //conf.setBoolean(name, value);
            conf.set("dfs.client.failover.proxy.provider."+ClusterName, 
                    "org.apache.hadoop.hdfs.server.namenode.ha.ConfiguredFailoverProxyProvider");
        }

    上传文件到HDFS的代码如下,至于读取等其他操作,可以参考网络上其他文章。

    /**
         * 上传文件到HDFS上去
         */
        private static void uploadToHdfs() throws IOException {
            String localSrc = "E:\test\article01.txt";
            String dst = "/user/test/article04.txt";
            FileSystem fs = FileSystem.get(URI.create(HADOOP_URL), conf);
            long start = new Date().getTime();
    
           /* InputStream in = new FileInputStream(localSrc);
            InputStreamReader isr = new InputStreamReader(in, "GBK");
            OutputStream out = fs.create(new Path(HADOOP_URL+dst), true);
            IOUtils.copy(isr, out, "UTF8");*/
            
            //该方法更快
            FSDataOutputStream outputStream=fs.create(new Path(dst));
            String fileContent = FileUtils.readFileToString(new File(localSrc), "GBK");
            outputStream.write(fileContent.getBytes());
            outputStream.close();
            
            long end = new Date().getTime();
            System.out.println("use:"+(end-start));
            
        }
  • 相关阅读:
    The test form is only available for requests from the local machine
    64位Win7下,先安装Visual Studio,后安装IIS的设置步骤
    [转] 如何在 64 位的 Windows 7 中安裝 PLSQL DEVELOPER 8 和 Oracle 11g x64 Client
    excel对csv的转义
    js中没有引用的匿名函数调用方法
    缓存实现条件
    js对象成员的删除特性 (delete)
    js语法作用域之间的相关性
    【转】UBOOT之四:uboot.lds分析
    linux C 中的volatile使用
  • 原文地址:https://www.cnblogs.com/itboys/p/6832345.html
Copyright © 2011-2022 走看看