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_HdfsApi04 {
private static Logger log = Logger.getLogger(Hadoop_HdfsApi04.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("/user/navy/"));  // 列出檔案，hadoop的hdfs的根目錄
if(files==null || files.length<=0){
System.out.println("該目錄下沒有任何檔案...");
return;
}

System.out.println("當前目錄下的檔案資訊如下：");
for (FileStatus f : files) {
System.out.println("\t" + f.getPath().getName());
}

String fileName;

while(true){
System.out.print("請輸入要刪除的檔案的檔名：");
fileName=input.next();
Path path= new Path(fileName);

if( fs.delete(path, false) ){  // 檔案刪除檔案
log.debug("檔案 "+fileName+" 刪除成功...");
break;
}else{
log.debug("檔案 "+fileName+" 不存在, 請重新輸入...");
}
}
} catch (Exception e) {
log.error("hdfs操作失敗!!!", e);
}
}
}