Java.io.URL

1、编写java程序

package com.company;
import java.io.IOException;
import java.io.InputStream;
import java.net.MalformedURLException;
import java.net.URL;
import org.apache.hadoop.fs.FsUrlStreamHandlerFactory;
import org.apache.hadoop.io.IOUtils; public class Main {
static {
URL.setURLStreamHandlerFactory(new FsUrlStreamHandlerFactory());
} public static void main(String[] args) throws MalformedURLException,IOException {
InputStream in=null;
try{
in = new URL(args[0]).openStream();
IOUtils.copyBytes(in,System.out,4096,false);
}finally {
IOUtils.closeStream(in);
}
}
}

2、打包为javaWrkspace.jar

3、simon@simon-Lenovo-G400:~/software/hadoop$

bin/hadoop jar /home/simon/javaWrkspace/out/artifacts/javaWrkspace_jar/javaWrkspace.jar  hdfs://localhost:9000/test/hello

org.apache.hadoop.fs.FileSystem

1、

import java.io.IOException;
import java.io.InputStream;
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 hdfsclient {
public static void main(String[] args) throws IOException{
String uri="hdfs://localhost:9000/test/hello";
Configuration conf=new Configuration();
FileSystem fs = FileSystem.get(URI.create(uri),conf);
InputStream in=null;
try{
in = fs.open(new Path(uri));
IOUtils.copyBytes(in,System.out,4096,false);
}finally {
IOUtils.closeStream(in);
}
}
}

2、打包为javaWrkspace.jar

3、simon@simon-Lenovo-G400:~/software/hadoop$

bin/hadoop jar /home/simon/javaWrkspace/out/artifacts/javaWrkspace_jar2/javaWrkspace.jar  hdfsclient

最新文章

  1. 关于Unicode,字符集,字符编码,每个程序员都应该知道的事
  2. csuoj 1117: 网格中的三角形
  3. 20款时尚的 WordPress 企业模板【免费主题下载】
  4. Java基础知识强化之网络编程笔记24:Android网络通信之 AndroidAsync(基于nio的异步通信库)
  5. ASP和PHP限制IP访问 只允许指定IP访问 允许*号通配符过滤IP
  6. BZOJ_1202_狡猾的商人_(并查集)
  7. FoxOne---一个快速高效的BS框架
  8. 【软件技巧】Sublime Text为不同语法定义不同高亮
  9. Eidtplus常用快捷键
  10. 剑指offier第10题
  11. 查询在应用程序运行得很慢, 但在SSMS运行得很快的原因探究
  12. IdentityServer4(10)- 添加对外部认证的支持之QQ登录
  13. phpstudy本地搭建域名访问
  14. Qt msvc 乱码如何解决?
  15. DBA_OBJECTS
  16. Flask的上下文源码剖析
  17. 《Python》线程之锁、信号量、事件、条件、定时器、队列
  18. ES monitoring
  19. 慢慢来,比较快。四年Android,共勉。
  20. pytesser模块WindowsError错误解决方法

热门文章

  1. 什么是数据库ACID?
  2. ansible-playbook 进行批量安装tomcat8
  3. C语言初学者关于数组指针的深度讨论
  4. Mysql字段名与保留字冲突导致的异常解决
  5. 深入浅出Tomcat/4 - Tomcat容器
  6. MySQL表结构变更,不可不知的Metadata Lock
  7. Java字符串操作及与C#字符串操作的不同
  8. spark 2.3 导致driver OOM的一个SparkPlanGraphWrapper源码的bug
  9. RabbitMQ教程(二) ——linux下安装rabbitmq
  10. .net Core 调用微信Jsapi接口,H5解析二维码