千家信息网

HDFS API如何实现Helloworld

发表于:2025-12-02 作者:千家信息网编辑
千家信息网最后更新 2025年12月02日,小编给大家分享一下HDFS API如何实现Helloworld,希望大家阅读完这篇文章之后都有所收获,下面让我们一起去探讨吧!1、源码import org.apache.hadoop.fs.FsUrl
千家信息网最后更新 2025年12月02日HDFS API如何实现Helloworld

小编给大家分享一下HDFS API如何实现Helloworld,希望大家阅读完这篇文章之后都有所收获,下面让我们一起去探讨吧!

1、源码

import org.apache.hadoop.fs.FsUrlStreamHandlerFactory;import org.apache.hadoop.io.IOUtils;import java.io.InputStream;import java.net.URL;/** * Example 3.1 */public class URLCat {    static {        URL.setURLStreamHandlerFactory(new FsUrlStreamHandlerFactory());    }    public static void main(String[] args) throws Exception {        InputStream in = null;        try {            in = new URL(args[0]).openStream();            IOUtils.copyBytes(in, System.out, 4096, false);        } finally {            IOUtils.closeStream(in);        }    }}
package cn.kissoft.hadoop.week04;import org.apache.hadoop.conf.Configuration;import org.apache.hadoop.fs.FileSystem;import org.apache.hadoop.fs.Path;import org.apache.hadoop.io.IOUtils;import java.io.InputStream;import java.net.URI;/** * Example 3.2 */public class Homework1 {    public static void main(String[] args) throws Exception {        String uri = args[0];        Configuration conf = new Configuration();        FileSystem fs = FileSystem.get(URI.create(uri), conf);        InputStream in = null;        try {            in = fs.open(new Path(uri));            IOUtils.copyBytes(in, System.out, 4096, false);        } finally {            IOUtils.closeStream(in);        }    }}

2、.class的运行方式

注意:本示例中URLCat类在default package中,如果有包,那类名前面还是要加上包。

3、.jar的运行方式

看完了这篇文章,相信你对"HDFS API如何实现Helloworld"有了一定的了解,如果想了解更多相关知识,欢迎关注行业资讯频道,感谢各位的阅读!

0