Hadoop FileSystem API读取数据实例简单注释

论坛 期权论坛 编程之家     
选择匿名的用户   2021-5-29 09:59   571   0

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;

// vv FileSystemCat public class FileSystemCat {

public static void main(String[] args) throws Exception { String uri = args[0];//uri 被赋值为第一个参数 Configuration conf = new Configuration();//新的接口 FileSystem fs = FileSystem.get(URI.create(uri),conf);//得到FileSystem实例 InputStream in = null; try { in = fs.open(new Path(uri));//打开 得到的是FSInputDataStream对象 IOUtils.copyBytes(in, System.out, 4096, false);//显示 } finally { IOUtils.closeStream(in); } } }


分享到 :
0 人收藏
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

积分:3875789
帖子:775174
精华:0
期权论坛 期权论坛
发布
内容

下载期权论坛手机APP