使用JDK中的类URL访问HDFS(来自吴超Hadoop)
2016-03-14 00:12
513 查看
package hdfs; import java.io.InputStream; import java.net.URL; import org.apache.hadoop.fs.FsUrlStreamHandlerFactory; import org.apache.hadoop.io.IOUtils; public class App1 { /** * 抛异常: unknown host: chaoren * 原因:是因为本机没有解析主机名chaoren */ static final String PATH = "hdfs://chaoren:9000/hello"; public static void main(String[] args) throws Exception { URL.setURLStreamHandlerFactory(new FsUrlStreamHandlerFactory()); final URL url = new URL(PATH); final InputStream in = url.openStream(); /** * @param in 表示输入流 * @param out 表示输出流 * @param buffSize 表示缓冲大小 * @param close 表示在传输结束后是否关闭流 */ IOUtils.copyBytes(in, System.out, 1024, true); } }
package hdfs;
import java.io.InputStream;import java.net.URL;
import org.apache.hadoop.fs.FsUrlStreamHandlerFactory;import org.apache.hadoop.io.IOUtils;
public class App1 {/** * 抛异常: unknown host: chaoren * 原因:是因为本机没有解析主机名chaoren */static final String PATH = "hdfs://chaoren:9000/hello";public static void main(String[] args) throws Exception {URL.setURLStreamHandlerFactory(new FsUrlStreamHandlerFactory());final URL url = new URL(PATH);final InputStream in = url.openStream();/** * @param in表示输入流 * @param out表示输出流 * @param buffSize表示缓冲大小 * @param close 表示在传输结束后是否关闭流 */IOUtils.copyBytes(in, System.out, 1024, true);}}
相关文章推荐
- 自动拆装箱与x类型
- Eclipse中项目红叉但找不到错误解决方法
- 配置JDK
- 更好的使用Java集合(二)
- 更好的使用Java集合(三)
- 简洁的Java四舍五入保留2位小数!!不需要导入其他包
- Java compiler level does not match the version of the installed Java project facet.
- spring IOC DI简单理解
- 深入理解java内存模型
- Java-J2SE基础复习
- SpringMVC 拦截 controller并解析接口平台
- SpringMVC 拦截web端登录
- SpringMVC 拦截class,method注解可替换方法
- java后端书架
- Eclipse+Maven快速生成Web项目,解决部署时Maven lib依赖问题
- java中Scanner的用法。
- java第二周学习总结
- eclipse fat jar 打包插件
- Java 中的语法糖 (Syntactic Sugar)
- Java heap space解决方法