window eclipse 访问远程虚拟机 Hdfs
2016-05-20 09:08
453 查看
package com.ibm.w3;
import java.net.URI;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FSDataInputStream;
import org.apache.hadoop.fs.FSDataOutputStream;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.IOUtils;
public class Dtf {
final public static String HDFS_PATH ="hdfs://dias:9000";
public static final String DIR_PATH ="/d10000";
public static final String FILE_PATH ="/d10000/f11111";
public static void main(String[] args) throws Exception {
// TODO Auto-generated method stub
final FileSystem fileSystem = FileSystem.get(new URI(HDFS_PATH), new Configuration());
//create folder
//fileSystem.mkdirs(new Path(DIR_PATH));
// upload
//final FSDataOutputStream out=fileSystem.create(new Path(FILE_PATH));
//FileInputStream in = new FileInputStream("C:/workplacebus/business/Important memo.txt");
//IOUtils.copyBytes(in, out, 1024,true);
//download
//final FSDataInputStream in = fileSystem.open(new Path(FILE_PATH));
//IOUtils.copyBytes(in, System.out, 1024, true);
//remove files
fileSystem.delete(new Path(FILE_PATH), true);
}
}
----------------------------------------
Eclipse windows 环境配置 请 参考优秀博文 :
http://my.oschina.net/lanzp/blog/309078?fromerr=blt5oYkF
import java.net.URI;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FSDataInputStream;
import org.apache.hadoop.fs.FSDataOutputStream;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.IOUtils;
public class Dtf {
final public static String HDFS_PATH ="hdfs://dias:9000";
public static final String DIR_PATH ="/d10000";
public static final String FILE_PATH ="/d10000/f11111";
public static void main(String[] args) throws Exception {
// TODO Auto-generated method stub
final FileSystem fileSystem = FileSystem.get(new URI(HDFS_PATH), new Configuration());
//create folder
//fileSystem.mkdirs(new Path(DIR_PATH));
// upload
//final FSDataOutputStream out=fileSystem.create(new Path(FILE_PATH));
//FileInputStream in = new FileInputStream("C:/workplacebus/business/Important memo.txt");
//IOUtils.copyBytes(in, out, 1024,true);
//download
//final FSDataInputStream in = fileSystem.open(new Path(FILE_PATH));
//IOUtils.copyBytes(in, System.out, 1024, true);
//remove files
fileSystem.delete(new Path(FILE_PATH), true);
}
}
----------------------------------------
Eclipse windows 环境配置 请 参考优秀博文 :
http://my.oschina.net/lanzp/blog/309078?fromerr=blt5oYkF
相关文章推荐
- java学习笔记5.20
- Myeclipse在线集成svn
- myeclipse10破解后,导出war包时报“SECURITY ALERT: INTEGERITY CHECK ERROR”进行了破解
- 简单谈谈Java类与类之间的关系
- Java的基础语法学习笔记
- Spring 异常捕获+log4j日志
- 292NimGame.java
- 如何手动配置Struts2项目
- Eclipse安装使用git管理项目
- java集合类
- [Java A] – is not an enclosing class
- Java通过ASCII码判断是否为数字
- Struts2框架action路径问题心得----》页面url请求怎么找action
- [译]Spring构建微服务
- JAVA 随机数和数学运算
- eclipse 代码中突然出现特殊字符
- Java内存溢出解决办法
- java字节码入门(上)
- Java设计模式(一) 简单工厂模式不简单
- Java设计模式(二) 工厂方法模式