Hadoop HDFS编程 API入门系列之HDFS_HA(五)
2016-12-13 23:53
736 查看
不多说,直接上代码。
[b]代码[/b]
[b]代码[/b]
package zhouls.bigdata.myWholeHadoop.HDFS.hdfs3; import java.io.FileInputStream; import java.io.InputStream; import java.io.OutputStream; import java.net.URI; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; import org.apache.hadoop.io.IOUtils; public class HDFS_HA { public static void main(String[] args) throws Exception { Configuration conf = new Configuration(); conf.set("fs.defaultFS", "hdfs://ns1"); conf.set("dfs.nameservices", "ns1"); conf.set("dfs.ha.namenodes.ns1", "nn1,nn2"); conf.set("dfs.namenode.rpc-address.ns1.nn1", "hadoop01:9000"); conf.set("dfs.namenode.rpc-address.ns1.nn2", "hadoop02:9000"); //conf.setBoolean(name, value); conf.set("dfs.client.failover.proxy.provider.ns1", "org.apache.hadoop.hdfs.server.namenode.ha.ConfiguredFailoverProxyProvider"); FileSystem fs = FileSystem.get(new URI("hdfs://ns1"), conf, "hadoop"); InputStream in =new FileInputStream("D://eclipse.rar"); OutputStream out = fs.create(new Path("/eclipse")); IOUtils.copyBytes(in, out, 4096, true); } }
相关文章推荐
- Hadoop HDFS编程 API入门系列之路径过滤上传多个文件到HDFS(二)
- Hadoop HDFS编程 API入门系列之合并小文件到HDFS(三)
- Hadoop HDFS编程 API入门系列之HdfsUtil版本2(七)
- Hadoop HDFS编程 API入门系列之RPC版本2(九)
- Hadoop HDFS编程 API入门系列之HdfsUtil版本1(六)
- Hadoop HDFS编程 API入门系列之从本地上传文件到HDFS(一)
- Hadoop HDFS编程 API入门系列之RPC版本1(八)
- Hadoop HDFS编程 API入门系列之简单综合版本1(四)
- Hadoop MapReduce编程 API入门系列之分区和合并(十四)
- Hadoop MapReduce编程 API入门系列之计数器(二十七)
- Hadoop MapReduce编程 API入门系列之统计学生成绩版本2(十八)
- Hadoop MapReduce编程 API入门系列之小文件合并(二十九)
- Hadoop MapReduce编程 API入门系列之压缩和计数器(三十)
- 【Hadoop入门学习系列之二】HDFS架构和编程
- Hadoop MapReduce编程 API入门系列之FOF(Fund of Fund)(二十三)
- Hadoop MapReduce编程 API入门系列之倒排索引(二十四)
- Hadoop MapReduce编程 API入门系列之wordcount版本2(六)
- Hadoop MapReduce编程 API入门系列之MapReduce多种输出格式分析(十九)
- Hadoop MapReduce编程 API入门系列之挖掘气象数据版本2(十)
- Hadoop MapReduce编程 API入门系列之MapReduce多种输入格式(十七)