进口java.io.ByteArrayOutputStream;
进口java.io.FileInputStream;
进口java.io.FileOutputStream;
进口java.io.InputStream;
进口java.net.URL;
进口org.apache.hadoop.conf.Configuration;
进口org.apache.hadoop.fs.FSDataInputStream;
进口org.apache.hadoop.fs.FSDataOutputStream;
进口org.apache.hadoop.fs.FileStatus;
进口org.apache.hadoop.fs.FileSystem;
进口org.apache.hadoop.fs.FsUrlStreamHandlerFactory;
进口org.apache.hadoop.fs.Path;
进口org.apache.hadoop.io.IOUtils;
进口org.junit.Test;
公共类listfilestrcutor {
/* *
*列出文件目录结构*/
@Test
公共空间listNum()抛出异常{
//创建配置对象,有个默认的加载顺序,先从core-default.xml,再到src目录中的文件,这里
//我们给定了
,,,,配置配置=new配置();
,,,,//修改当前文件的副本数量
,,,,conf.set (“dfs。复制”、“4”);
,,,,//修改当前文件的块大小
,,,,conf.set (“dfs。blocksize”、“20480”);
,,,,文件系统fs=FileSystem.get(参看);
,,,,//定义一个URL的字符串
,,,,字符串文件=" hdfs://hadoop01:9000/user/hadoop”;
,,,,//通过一个URL的字符串构建一个路径对象
,,,,路径路径=new路径(文件);
,,,,浮置板轨道=fs.listStatus FileStatus[](路径),
,,,,浮置板轨道)(FileStatus fst0: {
,,,,System.out.println (fst0.getPath () +”: isFile ()=" + fst0.isFile ());
,,,,}
,,}
}
