浪人 发表于 2018-10-30 12:34:52

Hadoop的HDFS-javaapi

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

　　

　　
javac -classpath ../hadoop-core-1.2.1.jar URLCat.java
　　
hadoop URLCat hdfs://hadoop1:9000/user/hadoop/inp/test2.txt


页: [1]
查看完整版本: Hadoop的HDFS-javaapi