import java.io.ByteArrayOutputStream;java
import java.io.FileInputStream;apache
import java.io.FileOutputStream;ide
import java.io.InputStream;oop
import java.net.URL;spa
import org.apache.hadoop.conf.Configuration;.net
import org.apache.hadoop.fs.FSDataInputStream;xml
import org.apache.hadoop.fs.FSDataOutputStream;对象
import org.apache.hadoop.fs.FileStatus;hadoop
import org.apache.hadoop.fs.FileSystem;字符串
import org.apache.hadoop.fs.FsUrlStreamHandlerFactory;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.IOUtils;
import org.junit.Test;
public class listfilestrcutor {
/**
* 列出文件目录结构
*/
@Test
public void listNum() throws Exception {
//建立configuration对象,有个默认的加载顺序,先从core-default.xml,再到src目录中的文件,这里
//咱们给定了
Configuration conf = new Configuration();
//修改当前文件的副本数量
conf.set("dfs.replication", "4");
//修改当前文件的块大小
conf.set("dfs.blocksize", "20480");
FileSystem fs = FileSystem.get(conf);
//定义一个URL的字符串
String file = "hdfs://hadoop01:9000/user/hadoop";
//经过一个URL的字符串构建一个path对象
Path path = new Path(file);
FileStatus[] fst = fs.listStatus(path);
for(FileStatus fst0 : fst) {
System.out.println(fst0.getPath() + ": isFile() =" + fst0.isFile());
}
}
}