hafs查看文件信息

import java.io.FileNotFoundException;
import java.io.IOException;
import java.net.URI;
import java.net.URISyntaxException;

import org.apache.commons.io.FileUtils;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileStatus;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.LocatedFileStatus;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.fs.RemoteIterator;

public class test2 {
	static Configuration conf = new Configuration();
	static FileSystem fs =null;
	
	public static void main(String[] args) throws FileNotFoundException, IllegalArgumentException, IOException, InterruptedException, URISyntaxException {
		listfile();
	}
	// listfiles
	public static void listfile() throws FileNotFoundException, IllegalArgumentException, IOException, InterruptedException, URISyntaxException{
		FileSystem fs = FileSystem.get(new URI("hdfs://hadoop1:9000"),conf,"root");
		RemoteIterator<LocatedFileStatus> listFiles = fs.listFiles(new Path("/"), true);
		while(listFiles.hasNext()){
			LocatedFileStatus next = listFiles.next();
			System.out.println(next.getPath().getName());
		}
		fs.close();
	}
	//liststatus
	public static void listfiles() throws IOException, InterruptedException, URISyntaxException{
		FileSystem fs = FileSystem.get(new URI("hdfs://hadoop1:9000"),conf,"root");
		FileStatus[] listStatus = fs.listStatus(new Path("/"));
		for(FileStatus file:listStatus){
			System.out.println(file.isDirectory()?"文件夹":"文件");
			
		}
	}

	

}