博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Hadoop FSDataInputStream 流定位的例子
阅读量:6895 次
发布时间:2019-06-27

本文共 874 字,大约阅读时间需要 2 分钟。

不单独说明了,代码中的注释很详细了

 

 
  1. /** 
  2.  * 
  3.  * Description: 这个例子用于展示Hadoop的FSDataInputStream的流定位能力 
  4.  * 
  5.  * @author charles.wang 
  6.  * @created Mar 13, 2012 9:21:34 AM 
  7.  *  
  8.  */ 
  9. public class FileSystemCatSeekable { 
  10.      
  11.     public static void main(String [] args) throws Exception{ 
  12.          
  13.         //获取命令行参数 
  14.         String uri = args[0]; 
  15.          
  16.         Configuration conf = new Configuration(); 
  17.         conf.set("hadoop.job.ugi""root,root123"); 
  18.          
  19.          
  20.         //打开一个Hadoop FileSystem ,用FileSystem的静态方法获取之 
  21.         FileSystem fs = FileSystem.get(URI.create(uri) ,conf); 
  22.          
  23.         //打开一个InputStream 对象 
  24.         FSDataInputStream in = null
  25.          
  26.         try
  27.          
  28.         //让其指向FileSystem中由命令行提供的uri对应的路径 
  29.         in =fs.open(new Path (uri)); 
  30.          
  31.         //第一次读取 
  32.         IOUtils.copyBytes(in, System.out, 20false); 
  33.          
  34.         //让读头重新定位到文件起始地方 
  35.         in.seek(0); 
  36.          
  37.         //第二次读取 
  38.         IOUtils.copyBytes(in, System.out, 20false); 
  39.          
  40.         }catch (Exception ex){ 
  41.             ex.printStackTrace(); 
  42.         }finally
  43.             in.close(); 
  44.         } 
  45.     } 
本文转自 charles_wang888 51CTO博客,原文链接:http://blog.51cto.com/supercharles888/840725,如需转载请自行联系原作者
你可能感兴趣的文章
流 (网络流)
查看>>
DOS命令之at命令详解
查看>>
vs2017莫名自动退出调试状态可以尝试一下如下的方法
查看>>
教你搞定ElasticSearch(head)
查看>>
Mac解压缩速度贼慢?那你一定要看看这个!
查看>>
使用PHP+Sphinx建立高效的站内搜索引擎
查看>>
Fastjson中以is打头出现的问题,会生成两个变量
查看>>
HTTP API网关选择之一Kong介绍
查看>>
基于Redis构建10万+终端级的高性能部标JT808协议的Gps网关服务器(转)
查看>>
把搜狗输入法词库导入Google拼音输入法
查看>>
利用反射将IDataReader读取到实体类中效率低下的解决办法
查看>>
用ndp部署storm应用
查看>>
【Java】监控远程服务器JVM
查看>>
JVM系列第12讲:JVM参数之查看JVM参数
查看>>
Spring中加载xml配置文件的六种方式
查看>>
android Fragments详解二:创建Fragment
查看>>
知道创宇 - 中文版putty后门事件分析
查看>>
电子政务信息交换平台与数据中心的构建(转)
查看>>
妄撮小游戏的开发思想-Android开发资料-《妄撮(撕开美女衣服)》游戏源代码外传...
查看>>
用ethtool确定多网卡Linux服务器网口位置
查看>>