HDFS文件系统在JAVA中的操作(1) 读取文件
2014-07-24 17:21
399 查看
#初学HADOOP,纯粹分享自己的学习经验,如果有操作错误可以在提出来
#共同学习,共同进步
#读取hdfs文件名为bb.text的文件,如下图
废话不说,直接上代码:
public
static final String HDFS_PATH="hdfs://master:9000/bb.text";//注:master为namenode节点的主机名
public
static void main(String[] args)throws Exception {
final FileSystemfileSystem=FileSystem.get(new URI(HDFS_PATH),newConfiguration());
//
//读取文件
//readHdfs(fileSystem); //取消些行注释即可
}
protected
static void readHdfs(FileSystemfileSystem) {
//readHdfs
//Configuration conn=new Configuration();
//fileSystem.get()
//InputStream in=null;
FSDataInputStreamin =null;
try {
in=fileSystem.open(new Path(HDFS_PATH));
IOUtils.copyBytes(in,System.out,1024,true);
}catch(Exception e) {
// TODO: handle exception
}finally{
IOUtils.closeStream(in);
}
}
运行的话,就能在输出那看到bb.text的内容了
#共同学习,共同进步
#读取hdfs文件名为bb.text的文件,如下图
废话不说,直接上代码:
public
static final String HDFS_PATH="hdfs://master:9000/bb.text";//注:master为namenode节点的主机名
public
static void main(String[] args)throws Exception {
final FileSystemfileSystem=FileSystem.get(new URI(HDFS_PATH),newConfiguration());
//
//读取文件
//readHdfs(fileSystem); //取消些行注释即可
}
protected
static void readHdfs(FileSystemfileSystem) {
//readHdfs
//Configuration conn=new Configuration();
//fileSystem.get()
//InputStream in=null;
FSDataInputStreamin =null;
try {
in=fileSystem.open(new Path(HDFS_PATH));
IOUtils.copyBytes(in,System.out,1024,true);
}catch(Exception e) {
// TODO: handle exception
}finally{
IOUtils.closeStream(in);
}
}
运行的话,就能在输出那看到bb.text的内容了
相关文章推荐
- java操作hdfs 创建文件 删除文件 读取文件
- HDFS文件系统操作JAVA-API
- java操作HDFS文件系统
- java 文件系统 及HDFS系统读取目录下文件对比
- 排坑!java操作hadoop中的hdfs文件系统
- JAVA API操作HDFS文件系统
- 从HDFS读取文件,把记录存到Hbase的java API操作
- java实现对hdfs文件系统的上传,下载,删除,创建文件夹的操作演示
- hdfs文件系统中相互复制的java操作
- HDFS的java接口——简化HDFS文件系统操作
- JAVA实现:将文件从本地上传到HDFS上、从HDFS上读取等操作
- HDFS的java接口——简化HDFS文件系统操作
- java操作hdfs文件系统上的文件
- HDFS文件系统简单的Java读写操作
- JAVA API操作HDFS文件系统
- Hadoop实验:用java把hdfs系统里的文件内容读取出来,显示到屏幕
- Java配置文件Properties的读取、写入与更新操作
- 用java读取各种计算机文件系统的文件列表(转)
- 对HDFS文件系统文件的读、写、删操作
- JAVA读取大文件操作