Hadoop的FileStatus简单使用

忘是亡心i 2022-07-28 08:53 267阅读 0赞

Hadoop的FileStatus简单使用  
  
FileStatus类继承关系：  
![Center][]  
  
  
FileStatus类的属性和方法：  
  
![Center 1][]  
  
  
输入文件信息：

blb@hadoop1:/home/blb/blb$ hdfs dfs -text /user/blb/libin/input/inputpath1.txt
    hadoop  a
    spark   a
    hive    a
    hbase   a
    tachyon a
    storm   a
    redis   a
    blb@hadoop1:/home/blb/blb$

代码：

import java.io.IOException;
    
    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.hadoop.fs.permission.FsPermission;
    import org.apache.hadoop.io.LongWritable;
    import org.apache.hadoop.io.NullWritable;
    import org.apache.hadoop.io.Text;
    import org.apache.hadoop.mapreduce.Job;
    import org.apache.hadoop.mapreduce.Mapper;
    import org.apache.hadoop.mapreduce.lib.input.FileInputFormat;
    import org.apache.hadoop.mapreduce.lib.input.TextInputFormat;
    import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat;
    import org.apache.hadoop.mapreduce.lib.output.TextOutputFormat;
    import org.apache.hadoop.util.GenericOptionsParser;
    
    
    public class GetStatusMapReduce {
    	public static void main(String[] args) throws IOException, ClassNotFoundException, InterruptedException {
    		Configuration conf = new Configuration();
    		String[] otherArgs = new GenericOptionsParser(conf, args).getRemainingArgs();
    		if(otherArgs.length!=2){
    			System.err.println("Usage databaseV1 <inputpath> <outputpath>");
    		}
    		conf.set("path", otherArgs[0]);
    		
    		Job job = Job.getInstance(conf, GetStatusMapReduce.class.getSimpleName() + "1");
    		job.setJarByClass(GetStatusMapReduce.class);
    		job.setMapOutputKeyClass(Text.class);
    		job.setMapOutputValueClass(Text.class);
    		job.setOutputKeyClass(Text.class);
    		job.setOutputValueClass(NullWritable.class);
    		job.setMapperClass(MyMapper1.class);
    		job.setNumReduceTasks(0);
    		job.setInputFormatClass(TextInputFormat.class);
    		job.setOutputFormatClass(TextOutputFormat.class);
    		FileInputFormat.addInputPath(job, new Path(otherArgs[0]));
    		FileOutputFormat.setOutputPath(job, new Path(otherArgs[1]));
    		job.waitForCompletion(true);
    	}
    	public static class MyMapper1 extends Mapper<LongWritable, Text, Text, NullWritable>{
    		@Override
    		protected void map(LongWritable key, Text value, Mapper<LongWritable, Text, Text, NullWritable>.Context context)
    				throws IOException, InterruptedException {
    			FileSystem fileSystem=FileSystem.get(context.getConfiguration());
    			FileStatus[] fileStatus=fileSystem.listStatus(new Path(context.getConfiguration().get("path")));
    			int length = fileStatus.length;
    			context.write(new Text("==================== 一次map函数 =============================="), NullWritable.get());
    			context.write(new Text("length--"+length), NullWritable.get());
    			for (FileStatus fs : fileStatus) {
    				long accessTime = fs.getAccessTime(); 
    				long blockSize = fs.getBlockSize();
    				Class<? extends FileStatus> class1 = fs.getClass();
    				String group = fs.getGroup();
    				long len = fs.getLen();
    				long modificationTime = fs.getModificationTime();
    				String owner = fs.getOwner();
    				Path path = fs.getPath();
    				FsPermission permission = fs.getPermission();
    				short replication = fs.getReplication();
    				//Path symlink = fs.getSymlink();
    				String string = fs.toString();
    				boolean directory = fs.isDirectory();
    				boolean encrypted = fs.isEncrypted();
    				boolean file = fs.isFile();
    				
    				context.write(new Text("===================================================================================="), NullWritable.get());
    				context.write(new Text("accessTime--"+accessTime), NullWritable.get());
    				context.write(new Text("blockSize--"+blockSize), NullWritable.get());
    				context.write(new Text("class1--"+class1), NullWritable.get());
    				context.write(new Text("group--"+group), NullWritable.get());
    				context.write(new Text("len--"+len), NullWritable.get());
    				context.write(new Text("modificationTime--"+modificationTime), NullWritable.get());
    				context.write(new Text("owner--"+owner), NullWritable.get());
    				context.write(new Text("path--"+path), NullWritable.get());
    				context.write(new Text("permission--"+permission), NullWritable.get());
    				context.write(new Text("replication--"+replication), NullWritable.get());
    				//context.write(new Text("symlink--"+symlink), NullWritable.get());
    				context.write(new Text("string--"+string), NullWritable.get());
    				context.write(new Text("directory--"+directory), NullWritable.get());
    				context.write(new Text("encrypted--"+encrypted), NullWritable.get());
    				context.write(new Text("file--"+file), NullWritable.get());
    			}
    		}
    	}
    }

输出：

==================== 一次map函数 ==============================
    length--1
    ====================================================================================
    accessTime--1459406433657
    blockSize--268435456
    class1--class org.apache.hadoop.fs.FileStatus
    group--hadoop
    len--58
    modificationTime--1456301571884
    owner--blb
    path--hdfs://hadoop1:9000/user/blb/libin/input/inputpath1.txt
    permission--rw-r--r--
    replication--2
    string--FileStatus{path=hdfs://hadoop1:9000/user/blb/libin/input/inputpath1.txt; isDirectory=false; length=58; replication=2; blocksize=268435456; modification_time=1456301571884; access_time=1459406433657; owner=blb; group=hadoop; permission=rw-r--r--; isSymlink=false}
    directory--false
    encrypted--false
    file--true
    ==================== 一次map函数 ==============================
    length--1
    ====================================================================================
    accessTime--1459406433657
    blockSize--268435456
    class1--class org.apache.hadoop.fs.FileStatus
    group--hadoop
    len--58
    modificationTime--1456301571884
    owner--blb
    path--hdfs://hadoop1:9000/user/blb/libin/input/inputpath1.txt
    permission--rw-r--r--
    replication--2
    string--FileStatus{path=hdfs://hadoop1:9000/user/blb/libin/input/inputpath1.txt; isDirectory=false; length=58; replication=2; blocksize=268435456; modification_time=1456301571884; access_time=1459406433657; owner=blb; group=hadoop; permission=rw-r--r--; isSymlink=false}
    directory--false
    encrypted--false
    file--true
    ==================== 一次map函数 ==============================
    length--1
    ====================================================================================
    accessTime--1459406433657
    blockSize--268435456
    class1--class org.apache.hadoop.fs.FileStatus
    group--hadoop
    len--58
    modificationTime--1456301571884
    owner--blb
    path--hdfs://hadoop1:9000/user/blb/libin/input/inputpath1.txt
    permission--rw-r--r--
    replication--2
    string--FileStatus{path=hdfs://hadoop1:9000/user/blb/libin/input/inputpath1.txt; isDirectory=false; length=58; replication=2; blocksize=268435456; modification_time=1456301571884; access_time=1459406433657; owner=blb; group=hadoop; permission=rw-r--r--; isSymlink=false}
    directory--false
    encrypted--false
    file--true
    ==================== 一次map函数 ==============================
    length--1
    ====================================================================================
    accessTime--1459406433657
    blockSize--268435456
    class1--class org.apache.hadoop.fs.FileStatus
    group--hadoop
    len--58
    modificationTime--1456301571884
    owner--blb
    path--hdfs://hadoop1:9000/user/blb/libin/input/inputpath1.txt
    permission--rw-r--r--
    replication--2
    string--FileStatus{path=hdfs://hadoop1:9000/user/blb/libin/input/inputpath1.txt; isDirectory=false; length=58; replication=2; blocksize=268435456; modification_time=1456301571884; access_time=1459406433657; owner=blb; group=hadoop; permission=rw-r--r--; isSymlink=false}
    directory--false
    encrypted--false
    file--true
    ==================== 一次map函数 ==============================
    length--1
    ====================================================================================
    accessTime--1459406433657
    blockSize--268435456
    class1--class org.apache.hadoop.fs.FileStatus
    group--hadoop
    len--58
    modificationTime--1456301571884
    owner--blb
    path--hdfs://hadoop1:9000/user/blb/libin/input/inputpath1.txt
    permission--rw-r--r--
    replication--2
    string--FileStatus{path=hdfs://hadoop1:9000/user/blb/libin/input/inputpath1.txt; isDirectory=false; length=58; replication=2; blocksize=268435456; modification_time=1456301571884; access_time=1459406433657; owner=blb; group=hadoop; permission=rw-r--r--; isSymlink=false}
    directory--false
    encrypted--false
    file--true
    ==================== 一次map函数 ==============================
    length--1
    ====================================================================================
    accessTime--1459406433657
    blockSize--268435456
    class1--class org.apache.hadoop.fs.FileStatus
    group--hadoop
    len--58
    modificationTime--1456301571884
    owner--blb
    path--hdfs://hadoop1:9000/user/blb/libin/input/inputpath1.txt
    permission--rw-r--r--
    replication--2
    string--FileStatus{path=hdfs://hadoop1:9000/user/blb/libin/input/inputpath1.txt; isDirectory=false; length=58; replication=2; blocksize=268435456; modification_time=1456301571884; access_time=1459406433657; owner=blb; group=hadoop; permission=rw-r--r--; isSymlink=false}
    directory--false
    encrypted--false
    file--true
    ==================== 一次map函数 ==============================
    length--1
    ====================================================================================
    accessTime--1459406433657
    blockSize--268435456
    class1--class org.apache.hadoop.fs.FileStatus
    group--hadoop
    len--58
    modificationTime--1456301571884
    owner--blb
    path--hdfs://hadoop1:9000/user/blb/libin/input/inputpath1.txt
    permission--rw-r--r--
    replication--2
    string--FileStatus{path=hdfs://hadoop1:9000/user/blb/libin/input/inputpath1.txt; isDirectory=false; length=58; replication=2; blocksize=268435456; modification_time=1456301571884; access_time=1459406433657; owner=blb; group=hadoop; permission=rw-r--r--; isSymlink=false}
    directory--false
    encrypted--false
    file--true

[Center]: /images/20220727/6268fa607cd64f1a94f6106061659dca.png
[Center 1]: /images/20220727/a05e18daccf94494bda85e835fdf7aa0.png