hadop 자바 API 파일 다운로드 실현
2947 단어 hadoop
package com.zlf;
import java.io.FileOutputStream;
import java.io.IOException;
import org.apache.commons.io.IOUtils;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FSDataInputStream;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
public class Demo {
public static void main(String[] args) throws IOException {
// TODO Auto-generated method stub
Configuration conf=new Configuration();
conf.set("fs.defaultFS", "hdfs://localhost:9000");
FileSystem fs=FileSystem.get(conf);
FSDataInputStream fsDataInputStream=fs.open(new Path("/RoseHA.rar"));
FileOutputStream fileOutputStream=new FileOutputStream("e:/RoseHA.rar");
IOUtils.copy(fsDataInputStream, fileOutputStream);
}
}
다음은 또 다른 실현 방식 으로 매우 간단 하 다.
fs.copyToLocalFile(new Path("/PowerDesigner15_Evaluation.rar"), new Path("e:/PowerDesigner15_Evaluation.rar"));