package com.yc.hadoop.hdfs;


import java.net.URI;
import java.util.Scanner;


import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileStatus;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.apache.log4j.Logger;


/**
 * 下載hdfs上的指定檔案到本地
 * @company 源辰資訊
 * @author navy
 */
public class Hadoop_HdfsApi06 {
private static Logger log = Logger.getLogger(Hadoop_HdfsApi06.class);  // 建立日誌記錄器


@SuppressWarnings("resource")
public static void main(String[] args) {
Scanner input = new Scanner(System.in);
FileSystem fs = null;
try {
Configuration conf = new Configuration(); // 載入配置檔案
URI uri = new URI("hdfs://192.168.30.130:9000/");  // 連線資源位置
fs = FileSystem.get(uri, conf ,"navy");  // 建立檔案系統例項物件


FileStatus[] files = fs.listStatus(new Path("/input/"));  // 列出檔案

System.out.println("可以選擇的檔名：");
for (FileStatus f : files) {
System.out.println("\t" + f.getPath().getName());
}
System.out.print("請輸入要下載的檔名：");
Path p= new Path("/input/"+input.next());

System.out.print("下載檔案存放目錄：");
Path dst=new Path(input.next());

// 注意：此時必須在window裡面配置hadoop環境，必須定位winutils.exe檔案
fs.copyToLocalFile(false,p,dst,true); // 最後一個引數表示不用原始的本地檔案系統，改用java的io流 

log.debug("下載成功....");

} catch (Exception e) {
log.error("hdfs操作失敗!!!", e);
}
}
}