国产片侵犯亲女视频播放_亚洲精品二区_在线免费国产视频_欧美精品一区二区三区在线_少妇久久久_在线观看av不卡

服務(wù)器之家:專注于服務(wù)器技術(shù)及軟件下載分享
分類導(dǎo)航

PHP教程|ASP.NET教程|JAVA教程|ASP教程|

香港云服务器
服務(wù)器之家 - 編程語言 - JAVA教程 - java連接hdfs ha和調(diào)用mapreduce jar示例

java連接hdfs ha和調(diào)用mapreduce jar示例

2019-11-16 14:10java教程網(wǎng) JAVA教程

這篇文章主要介紹了Java API連接HDFS HA和調(diào)用MapReduce jar包,需要的朋友可以參考下

Java API 連接 HDFS HA 

復(fù)制代碼代碼如下:

public static void main(String[] args) {
  Configuration conf = new Configuration();
  conf.set("fs.defaultFS", "hdfs://hadoop2cluster");
  conf.set("dfs.nameservices", "hadoop2cluster");
  conf.set("dfs.ha.namenodes.hadoop2cluster", "nn1,nn2");
  conf.set("dfs.namenode.rpc-address.hadoop2cluster.nn1", "10.0.1.165:8020");
  conf.set("dfs.namenode.rpc-address.hadoop2cluster.nn2", "10.0.1.166:8020");
  conf.set("dfs.client.failover.proxy.provider.hadoop2cluster",        "org.apache.hadoop.hdfs.server.namenode.ha.ConfiguredFailoverProxyProvider");
  FileSystem fs = null;
  try {
     fs = FileSystem.get(conf);
     FileStatus[] list = fs.listStatus(new Path("/"));
     for (FileStatus file : list) {
       System.out.println(file.getPath().getName());
      }
  } catch (IOException e) {
     e.printStackTrace();
  } finally{
      try {
        fs.close();
      } catch (IOException e) {
        e.printStackTrace();
      }
  }
}

 

Java API調(diào)用MapReduce程序

 

復(fù)制代碼代碼如下:

String[] args = new String[24];
args[0] = “/usr/hadoop-2.2.0/share/hadoop/mapreduce/hadoop-mapreduce-examples-2.2.0.jar";
args[1] = "wordcount";
args[2] = "-D";
args[3] = "yarn.resourcemanager.address=10.0.1.165:8032";
args[4] = "-D";
args[5] = "yarn.resourcemanager.scheduler.address=10.0.1.165:8030";
args[6] = "-D";
args[7] = "fs.defaultFS=hdfs://hadoop2cluster/";
args[8] = "-D";
args[9] = "dfs.nameservices=hadoop2cluster";
args[10] = "-D";
args[11] = "dfs.ha.namenodes.hadoop2cluster=nn1,nn2";
args[12] = "-D";
args[13] = "dfs.namenode.rpc-address.hadoop2cluster.nn1=10.0.1.165:8020";
args[14] = "-D";
args[15] = "dfs.namenode.rpc-address.hadoop2cluster.nn2=10.0.1.166:8020";
args[16] = "-D";
args[17] = "dfs.client.failover.proxy.provider.hadoop2cluster=org.apache.hadoop.hdfs.server.namenode.ha.ConfiguredFailoverProxyProvider";
args[18] = "-D";
args[19] = "fs.hdfs.impl=org.apache.hadoop.hdfs.DistributedFileSystem";
args[20] = "-D";
args[21] = "mapreduce.framework.name=yarn";
args[22] = "/input";
args[23] = "/out01";
RunJar.main(args);

延伸 · 閱讀

精彩推薦
662
主站蜘蛛池模板: 91免费小视频 | 91精品在线看 | 直接看av的网站 | 黑森林av凹凸导航 | 国产黄色在线网站 | 欧美一级二级视频 | 青青草99| 97伦理片 | 日韩中文字幕在线免费观看 | 亚洲精品国偷拍自产在线观看 | 欧美综合一区 | 欧美日本在线观看 | 亚洲国产精品网站 | 在线观看国产一区 | 免费成人高清在线视频 | 亚洲精品久久久久久国产精华液 | 国产一区二区三区四 | 成人免费观看49www在线观看 | 免费观看黄视频网站 | av在线日韩| 欧洲一区在线 | 一区二区欧美在线 | 黄色一区二区三区 | 午夜小视频在线观看 | 亚洲精品一区二区三区在线 | 色就是色网站 | 国产一区二区三区四区五区密私 | 真实国产露脸乱 | 2022天天操 | 一级特黄av| 好吊妞国产欧美日韩免费观看视频 | 网站黄色在线免费观看 | 国产一区二区三区免费看 | 1a级毛片免费观看 | 四虎永久免费影院 | 亚州成人 | 日韩一区二区三区精品 | 99久久久国产精品 | 国产一级纯肉体一级毛片 | 91香蕉视频在线 | 日本中文在线视频 |