hadoop第一个例子
2024-09-29 04:31:27
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
最新文章
- 关于Unicode,字符集,字符编码,每个程序员都应该知道的事
- csuoj 1117: 网格中的三角形
- 20款时尚的 WordPress 企业模板【免费主题下载】
- Java基础知识强化之网络编程笔记24:Android网络通信之 AndroidAsync(基于nio的异步通信库)
- ASP和PHP限制IP访问 只允许指定IP访问 允许*号通配符过滤IP
- BZOJ_1202_狡猾的商人_(并查集)
- FoxOne---一个快速高效的BS框架
- 【软件技巧】Sublime Text为不同语法定义不同高亮
- Eidtplus常用快捷键
- 剑指offier第10题
- 查询在应用程序运行得很慢, 但在SSMS运行得很快的原因探究
- IdentityServer4(10)- 添加对外部认证的支持之QQ登录
- phpstudy本地搭建域名访问
- Qt msvc 乱码如何解决?
- DBA_OBJECTS
- Flask的上下文源码剖析
- 《Python》线程之锁、信号量、事件、条件、定时器、队列
- ES monitoring
- 慢慢来,比较快。四年Android,共勉。
- pytesser模块WindowsError错误解决方法
热门文章
- 什么是数据库ACID?
- ansible-playbook 进行批量安装tomcat8
- C语言初学者关于数组指针的深度讨论
- Mysql字段名与保留字冲突导致的异常解决
- 深入浅出Tomcat/4 - Tomcat容器
- MySQL表结构变更,不可不知的Metadata Lock
- Java字符串操作及与C#字符串操作的不同
- spark 2.3 导致driver OOM的一个SparkPlanGraphWrapper源码的bug
- RabbitMQ教程(二) ——linux下安装rabbitmq
- .net Core 调用微信Jsapi接口,H5解析二维码