Shulou(Shulou.com)06/03 Report--

Import java.io.ByteArrayOutputStream

Import java.io.FileInputStream

Import java.io.FileOutputStream

Import java.io.InputStream

Import java.net.URL

Import org.apache.hadoop.conf.Configuration

Import org.apache.hadoop.fs.FSDataInputStream

Import org.apache.hadoop.fs.FSDataOutputStream

Import org.apache.hadoop.fs.FileStatus

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 {

/ * *

* list file directory structure

, /

@ Test

Public void listNum () throws Exception {

/ / create configuration objects, which have a default loading order, first from core-default.xml to the files in the src directory, here

/ / We have given

Configuration conf = new Configuration ()

/ / modify the number of copies of the current file

Conf.set ("dfs.replication", "4")

/ / modify the block size of the current file

Conf.set ("dfs.blocksize", "20480")

FileSystem fs = FileSystem.get (conf)

/ / define a string of URL

String file = "hdfs://hadoop01:9000/user/hadoop"

/ / construct a path object from a string of URL

Path path = new Path (file)

FileStatus [] fst = fs.listStatus (path)

For (FileStatus fst0: fst) {

System.out.println (fst0.getPath () + ": isFile () =" + fst0.isFile ())

}

}

}

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.