zoukankan      html  css  js  c++  java
  • Hadoop 从URL中读取数据

    package com.hadoop;
    
    import java.io.IOException;
    import java.io.InputStream;
    import java.net.URL;
    
    import org.apache.hadoop.fs.FsUrlStreamHandlerFactory;
    import org.apache.hadoop.io.IOUtils;
    
    public class URLCat {
    
    	static {
    		URL.setURLStreamHandlerFactory(new FsUrlStreamHandlerFactory());
    	}
    	
    	public static void main(String[] args) throws Exception, IOException {
    		
    		InputStream in = null;
    		try {
    			in = new URL(args[0]).openStream();
    			IOUtils.copyBytes(in, System.out, 4096,false);
    		} finally {
    			IOUtils.closeStream(in);
    		}
    	}
    }
    

     hadoop中运行:

     

  • 相关阅读:
    vue $emit的使用
    flask config 环境变量配置
    get请求
    下载及安装
    测试用例写作
    系统测试
    测试方法
    软件质量
    测试基础
    子网掩码
  • 原文地址:https://www.cnblogs.com/yixiwenwen/p/5587906.html
Copyright © 2011-2022 走看看