package com.huawei.hdfs; 

import org.apache.hadoop.conf.Configuration; 

import org.apache.hadoop.fs.FileSystem; 

import org.apache.hadoop.fs.Path; 

import java.io.IOException; 

public class IsFile { 

    public static void main(String[] args) throws IOException { 

        //用于加载 Hadoop 配置，请补充代码

        Configuration conf = 【填空1】; 

        //conf.set("fs.defaultFS", "hdfs:// master:9000"); 

        //创建文件系统的抽象类，用于操作HDFS

        FileSystem fs =【填空2】; 

        //指定/user/test/hdfs文件夹和/user/test/hdfs/file10.txt文件

        Path path1 = 【填空3】("/user/test/hdfs"); 

        Path path2 = 【填空3】("/user/test/hdfs/file10.txt"); 

        //判断目录是否存在 

        if (【填空4】(path1)) { 

            //输出函数是什么？

           【填空5】(path1+"目录已经存在"); 

        }else{ 

            //输出函数是什么？

            【填空5】path1+"目录不存在"); 

        } 

        //判断文件是否存在 

        if (【填空4】(path2)) { 

            //输出函数是什么？

            【填空5】(path2+"文件已经存在"); 

        }else{

            //输出函数是什么？

            【填空5】(path2+"文件不存在"); 

        } 

        //关闭文件

        【填空6】; 

    } 

}

import org.apache.hadoop.conf.Configuration; 

import org.apache.hadoop.fs.FSDataOutputStream; 

import org.apache.hadoop.fs.FileSystem; 

import org.apache.hadoop.fs.Path; 

import java.io.IOException; 

/** * 创建空白文件 */ 

public class CreateFile1 { 

    public static void main(String[] args) throws IOException { 

        Configuration conf = 【填空1：创建连接】; 

        //conf.set("fs.defaultFS", "hdfs:// master:9000"); 

        FileSystem fs = 【填空2：调用文件管理功能】; 

        boolean create = 【填空3：创建文件】(new Path("/user/test/hdfs/file10.txt")); 

        【填空4：输出函数】(create ? "创建成功":"创建失败,文件已经存在");

        【填空5：关闭】; 

    } 

}

import org.apache.hadoop.conf.Configuration; 

import org.apache.hadoop.fs.FSDataOutputStream; 

import org.apache.hadoop.fs.FileSystem; 

import org.apache.hadoop.fs.Path; 

import java.io.IOException; 

/** * 创建空白文件 */ 

public class CreateFile1 { 

    public static void main(String[] args) throws IOException { 

        Configuration conf = 【填空1：创建连接】; 

        //conf.set("fs.defaultFS", "hdfs:// master:9000"); 

        FileSystem fs = 【填空2：调用文件管理功能】; 

        boolean create = 【填空3：创建文件】("/user/test/hdfs/file10.txt")); 

        【填空4：输出函数】(create ? "创建成功":"创建失败,文件已经存在");

        fs.close(); 

    } 

}

import org.apache.hadoop.conf.Configuration; 

import org.apache.hadoop.fs.FSDataOutputStream; 

import org.apache.hadoop.fs.FileSystem; 

import org.apache.hadoop.fs.Path; 

import java.io.BufferedWriter; 

import java.io.IOException; 

import java.io.OutputStreamWriter; 

/** * 创建文件的同时向文件里面写入数据 */ 

public class CreateFile2 { 

    public static void main(String[] args) throws IOException { 

        Configuration conf = 【填空1：创建conf】; 

        //conf.set("fs.defaultFS", "hdfs:// master:9000"); 

        FileSystem fs = 【填空2：连接HDFS】; 

        Path path = 【填空3：文件路径】("/user/test/hdfs/file11.txt"); 

        FSDataOutputStream dos = 【填空4：新建文件】; 

        【填空5：输出函数】(path+"文件创建成功"); 

        BufferedWriter bw = 【填空6：包装输出流以便高效写入】; 

        bw.write("huawei"); 

        【填空7：换行】;

        bw.write("bigdata"); 

        【填空7：换行】;

        bw.write("java"); 

        【填空7：换行】;

        【填空8：关闭】;

    }

 }

import org.apache.hadoop.conf.Configuration; 

import org.apache.hadoop.fs.FSDataInputStream; 

import org.apache.hadoop.fs.FileSystem; 

import org.apache.hadoop.fs.Path; 

import java.io.BufferedReader; 

import java.io.IOException; 

import java.io.InputStreamReader; 

public class ScanFile { 

    public static void main(String[] args) throws IOException { 

        Configuration conf =【填空1：创建Hadoop配置对象conf】

        //conf.set("fs.defaultFS", "hdfs://master:9000");

        FileSystem fs =【填空2：获取文件系统实例】

        Path path = 【填空3：从命令行第一个参数获取文件路径并创建Path对象】

        FSDataInputStream red =【填空4：打开文件，返回输入流】

        BufferedReader bf =【填空5：red包装输入流以便逐行读取】

        String line = null; 

        while ((line = 【填空6：读取文件的每一行】) != null){ 

            System.out.println(line); 

        } 

        bf.close(); 

        red.close(); 

        fs.close(); 

    } 

}

import org.apache.hadoop.conf.Configuration; 

import org.apache.hadoop.fs.FileSystem; 

import org.apache.hadoop.fs.Path; 

import java.io.IOException; 

/** * 删除文件或目录 */ 

public class DeleteFile { 

    public static void main(String[] args) throws IOException { 

        Configuration conf = 【填空1：创建新的Hadoop配置对象】; 

        //conf.set("fs.defaultFS", "hdfs://master:9000"); 

        FileSystem fs = 【填空2：使用配置获取Hadoop文件系统实例】; 

        Path path =【填空3：从命令行第一个参数创建Path对象，表示要删除的文件目录路径】; 

        //exists判断的不仅仅是目录也是文件，使用delete可以将文件或者目录删除 

        if (【填空4：检查路径是否存在】) { 

            【填空5：递归删除目录及其内容】;

            System.out.println("删除成功"); 

        }else{ 

        System.out.println("文件不存在"); 

        } 

        fs.close(); 

    } 

}

    public static class MyMapper extends Mapper<LongWritable, Text, Text, LongWritable>{ 

    @Override 

    protected void map(LongWritable key, Text value, Mapper<LongWritable, Text, Text, LongWritable>.Context context) throws IOException, InterruptedException { 

        String line = 【填空1：将输入的值转换为字符串】; 

        String[] splited = 【填空2:按制表符分割字符串】; 

        for (String word : splited) { 

            Text k2 = 【填空3：取k2的值】; 

            LongWritable v2 = 【填空4：取v2的值】; 

            【填空5：对每个单词输出键值对】; 

            } 

        } 

    } 

    public static class MyReducer extends Reducer<Text, LongWritable, Text, LongWritable>{ 

    @Override 

    protected void reduce(Text k2, Iterable<LongWritable> v2s, Reducer<Text, LongWritable, Text, LongWritable>.Context context) throws IOException, InterruptedException { 

        long 【填空6：赋count的初始值】; 

        for (LongWritable times : v2s) { 

            【填空7：对count进行计算】; 

        } 

        LongWritable v3 = 【填空8：赋值v3】; 

        context.write(k2, v3); 

        } 

    } 

    public static void main(String[] args) throws Exception{ 

        Configuration conf =【填空9：创建Hadoop配置】; 

        Job job = Job.getInstance(conf , WordCountApp.class.getSimpleName()); 

        //必须指定 

        job.setJarByClass(【填空10】); 

        //指定本业务job要使用的Mapper业务类 

        job.setMapperClass(【填空11】); 

        //指定mapper输出数据的<k2,v2>的类型 

        job.setMapOutputKeyClass(【填空12】); 

        job.setMapOutputValueClass(【填空13】); 

        //指定本业务job要使用的Reducer业务类 

        job.setReducerClass(【填空14】); 

        //指定reducer输出数据的<k3,v3>的类型 

        job.setOutputKeyClass(【填空15】); 

        job.setOutputValueClass(【填空16】); 

        //输入数据来自哪里 

        FileInputFormat.setInputPaths(job, 【填空17】); 

        //输出数据写到哪里 

        FileOutputFormat.setOutputPath(job, 【填空18】)); 

        //true表示将运行进度等信息及时输出给用户 

        boolean res = job.waitForCompletion(true); 

        System.exit(res?0:1); 

    } 

}

  //转换为小写

  public Text evaluate(Text t){

    //默认是进行小写转换

    return 【填空1：默认进行小写转换】;

  }

  /*

   对参数进行大小写转换

   如果该值为lower，则进行小写转换，如果改值为upper则进行大写转换，其他情况不进行转换

   */

  public Text evaluate(Text t,String lowerOrUpper){

    if(【填空2：输入值是空值】){

      return t;

    }

    if(【填空3：lowerOrUpper输入值是lower】){

      //select lower_upper(studentname,'lower') from students;

      return 【填空4：t进行小写】;

    }else if(填空5：lowerOrUpper输入值是upper){

      //select lower_upper(studentname,'upper') from students;

      return 【填空6：t进行大写】;

    }

    //转换参数错误的情况下，直接返回原本的值

    return t;

  }

}