java实现将hdfs上的文件下载到本地系统上
2016-06-26 22:45
573 查看
/*** * 将hdfs上的文件下载到本地系统上1.0版本 */ package itcast; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.URI; import java.net.URISyntaxException; 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 HDFSDemo { public static void main(String[] args) throws IOException, URISyntaxException { // TODO Auto-generated method stub FileSystem fs = FileSystem.get(new URI("hdfs://itcast01:9000"), new Configuration()); InputStream in = fs.open(new Path("/Demo")); OutputStream out = new FileOutputStream("E://Demo"); IOUtils.copyBytes(in, out, 4096, true); } }
/*** * 将hdfs上的文件下载到本地系统上2.0版本 */ package itcast; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.URI; import java.net.URISyntaxException; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; import org.apache.hadoop.io.IOUtils; import org.junit.Before; public class HDFSDemo { FileSystem fs = null; @Before public void init() throws IOException, URISyntaxException{ fs = FileSystem.get(new URI("hdfs://itcast01:9000"), new Configuration()); } public static void main(String[] args) throws IOException, URISyntaxException { // TODO Auto-generated method stub FileSystem fs = FileSystem.get(new URI("hdfs://itcast01:9000"), new Configuration()); InputStream in = fs.open(new Path("/Demo")); OutputStream out = new FileOutputStream("E://Demo"); IOUtils.copyBytes(in, out, 4096, true); } }
相关文章推荐
- JAVA调用 keytool 生成keystore 和 cer 证书
- Spring MVC 中的 forward 和 redirect 的简单理解
- Java垃圾回收器
- java webservice 总结(学会读别人的webservice并且通过代理模式访问)
- spring framework release下载
- Hessian和Java反序列化问题小结
- 关于Spring
- springMVC实现文件上传
- (七)文档对象模型(DOM)(下)
- 《Java JD7 学习笔记》课后练习题2
- springMVC实现文件上传
- springmvc注解开发-数据回显
- SpringBoot入门系列:第六篇 mybatis
- Java 基础5(变量+构造方法)
- java并发之Fork/Join实例
- Eclipse下用 Gradle构建 Web Application
- Eclipse下用 Gradle构建 Web Application
- springmvc之自定义注解(annotation)
- 华为机试---路灯
- java String.split()函数的用法分析