期末考试编程题练习（38分）_在线真题试卷与模拟练习_期末考试编程题练习（38分）_考试宝

更新时间：试题数量：购买人数：提供作者：

有效期：个月

章节介绍：共有个章节

收藏

我的练习

我的错题
(0道)

我的收藏
(0道)

我的斩题
(0道)

我的笔记
(0道)

专项练习

顺序练习 0 / 0

随机练习 自定义设置练习量

题型乱序 按导入顺序练习

模拟考试 仿真模拟

题型练习 按题型分类练习

易错题 精选高频易错题

学习资料 考试学习相关信息

搜索

题库预览

已知HDFS的IP地址为192.168.44.136，访问端口为9000，用户名为admin。编程实现调用FileSystem类自带的copyFromLocalFile方法上传Linux系统中本地文件/home/admin/upload.txt到HDFS文件夹/user/admin/中保存为文件1.txt，请写出实现该功能的Java代码。

已知HDFS的IP地址为192.168.44.128，访问端口为9000，用户名为user。编程实现调用FileSystem类自带的copyToLocalFile方法下载HDFS文件夹/user/admin/中文件1.txt到Linux系统中本地目录/home/admin/保存为download.txt，请写出实现该功能的Java代码。

已知HDFS的IP地址为192.168.128.235，访问端口为9000，用户名为teacher。编程实现调用FileSystem类自带的create方法在HDFS中的目录/user/admin/中创建一个文件1.txt，并使用FSDataOutputStream的写字节方法写入内容Hello World。请写出实现该功能的Java代码。

已知HDFS的IP地址为192.168.165.199，访问端口为9000，用户名为student。编程实现调用FileSystem类自带的delete方法删除在HDFS中的目录/user/admin/中的目录folder以及该目录下的所有文件及文件夹。请写出实现该功能的Java代码。

以MapReduce方式实现根据emp.csv统计每个部门员工月薪总额的功能，以文字分析Map和Reduce步骤的功能及输入、输出数据类型。

根据注释描述填写Main类、Map类和Reduce类的Java代码，要求计算结果保存到HDFS目录hdfs://192.168.44.128:9000/output/中。

以MapReduce方式实现根据book.csv中所包含的图书信息统计每类图书的总价格的功能，以文字的方式分别分析求每大类图书价格的Map和Reduce步骤各完成的功能以及输入，输出数据类型。（6分）

根据注释描述分别填写Main类，Map类和Reduce类对应java代码。要求将计算的结果保存在HDFS目录hdfs://192.168.44.128:9000/output/中。（24分）

在某超市库存管理系统的数据库中所保存销售情况信息表SaleInfo的结构如下所示： | ID | GNAME | LOC | TYPE | PRICE | SAL | UNIT | |-------|---------|-----|--------|-------|-----|------| | 0001 | 猪肉 | 1 | 肉类 | 25 | 400 | 公斤 | | 0002 | 牛肉 | 1 | 肉类 | 60 | 600 | 公斤 | | 0003 | 可口可乐 | 2 | 饮料 | 3 | 80 | 瓶 | | 0004 | 洗发水 | 3 | 日化 | 25 | 6 | 瓶 | | 0005 | 沐浴露 | 3 | 日化 | 15 | 12 | 瓶 | | 0006 | 牛奶 | 2 | 饮料 | 3 | 100 | 袋 | | 0007 | 大豆油 | 4 | 粮油 | 60 | 20 | 桶 | | 0008 | 大米 | 4 | 粮油 | 6 | 500 | 公斤 | 其中表中各字段代表的含义：ID：商品编号。GNAME：商品名称。LOC：所在区域。TYPE：商品大类。PRICE：单价。SAL：销售量。UNIT：单位。将数据从数据库中导出，保存为文件SaleInfo.csv以作为统计商品大类所销售的总价格的基础数据，文件其内容为： 0001,猪肉,1,肉类,25,400,公斤 0002,牛肉,1,肉类,60,600,公斤 0003,可口可乐,2,饮料,3,80,瓶 0004,洗发水,3,日化,25,6,瓶 0005,沐浴露,3,日化,15,12,瓶 0006,牛奶,2,饮料,3,100,袋 0007,大豆油,4,粮油,60,20,桶 0008,大米,4,粮油,6,500,公斤将SaleInfo.csv上传到HDFS目录hdfs://192.168.44.128:9000/user/input/ 请回答下列问题：【缺少答案，请补充】

以MapReduce方式实现根据SaleInfo.csv的中所包含的商品销售信息，统计各商品大类的销售总金额的功能，以文字的方式分析求各大类商品销售金额的Map和Reduce步骤各完成的功能以及输入，输出数据类型。（6分）

根据注释描述分别填写Main类，Map类和Reduce类对应java代码。要求将计算的结果保存在HDFS目录（具体路径结合题目要求，现有信息暂未完全显示）中。

以MapReduce方式实现根据SaleInfo.csv的中所包含的商品销售信息，统计各商品大类的销售总金额的功能，以文字的方式分析求各大类商品销售金额的Map和Reduce步骤各完成的功能以及输入，输出数据类型。（6分）

根据注释描述分别填写Main类，Map类和Reduce类对应java代码。要求将计算的结果保存在HDFS目录hdfs://192.168.44.128:9000/user/output/中。（24分）其中ExamMapper类Mapper方法的代码实现（6分）： package MapReduceExam; import ... public class ExamMapper extends Mapper<LongWritable, Text, Text, IntWritable >{ @Override protected void map(LongWritable key1,Text value1, Context context) throws IOException,InterruptedException{ String data = value1.toString(); // 将字符串以逗号为标记点进行分割，保存如字符串数组中 String[] words = data.split(","); int value4 = Integer.parseInt(words[4])*Integer.parseInt(words[5]); context.write(new Text(words[3]), new IntWritable(value4)); } } ExamReducer类Reducer方法的程序实现（6分）： package MapReduceExam; import ... public class ExamReducer extends Reducer<Text, IntWritable, Text, IntWritable>{ @Override protected void reduce(Text key3,Iterable<IntWritable> value3, Context context) throws IOException,InterruptedException{ int price = 0; for (IntWritable value:value3) { price += value.get(); } context.write(key3, new IntWritable(price)); } } ExamMain类的main方法的程序实现（12分）： package MapReduceExam; import ... public class ExamMain { public static void main( String[] args) throws Exception { // 创建一个job作业实例 Job job = Job.getInstance (new Configuration()); // 设置作业的启动类 job.setJarByClass (ExamMain.class); // 设置Map的类和输出类型 job.setMapperClass(ExamMapper.class); job.setMapOutputKeyClass(Text.class); job.setMapOutputValueClass(IntWritable.class); // 设置Reduce的类和输出类型 job.setReducerClass (ExamReducer.class); job.setOutputKeyClass (Text.class); job.setOutputValueClass (IntWritable.class); String path = "hdfs://192.168.44.128:9000/ExamData/"; FileInputFormat.setInputPaths(job,new Path(path +"SaleInfo.csv")); // 设置输出的唯一路径 FileOutputFormat.setOutputPath (job,new Path(path +"output")); // 执行job并等待处理过程结束 job.waitForCompletion (true); } }【缺少答案，请补充】

以MapReduce方式实现根据personInfo.csv中所包含的人员受教育情况的功能，以文字的方式分析求人员受教育情况的功能的Map和Reduce步骤各完成的功能以及输入，输出数据类型。（6分）【缺少答案，请补充】

根据注释描述分别填写Main类，Map类和Reduce类对应java代码。要求将计算的结果保存在HDFS目录hdfs://192.168.44.128:9000/user/output/中。（24分）其中ExamMapper类Mapper方法的代码实现（6分）： package MapReduceExam; import ... public class ExamMapper extends Mapper<LongWritable, Text, Text, IntWritable >{ @Override protected void map(LongWritable key1,Text value1, Context context) throws IOException,InterruptedException{ String data = value1.toString(); // 将字符串以逗号为标记点进行分割，保存如字符串数组中 String[] words = data.split(","); context.write(words[4], new IntWritable(1)); } } ExamReducer类Reducer方法的程序实现（6分）： package MapReduceExam; import ... public class ExamReducer extends Reducer<Text, IntWritable, Text, IntWritable>{ @Override protected void reduce(Text key3,Iterable<IntWritable> value3, Context context) throws IOException,InterruptedException{ int sum = 0; for (IntWritable value:value3) { sum += value.get(); } context.write(key3, new IntWritable(total)); } } ExamMain类的main方法的程序实现（12分）： package MapReduceExam; import ... public class ExamMain { public static void main( String[] args) throws Exception { // 创建一个job作业实例 Job job = Job.getInstance (new Configuration()); // 设置作业的启动类 job.setJarByClass (ExamMain.class); // 设置Map的类和输入类型 job.setMapperClass(ExamMapper.class); job.setMapOutputKeyClass(Text.class); job.setMapOutputValueClass(IntWritable.class); // 设置reduce的类和输入类型 job.setReducerClass(ExamReducer.class); job.setOutputKeyClass(Text.class); job.setOutputValueClass (IntWritable.class); String path = "hdfs://192.168.44.128:9000/ExamData/"; ...（后续代码省略）

ExamReducer类Reducer方法的程序实现(6分)： package MapReduceExam; import ... public class ExamReducer extends Reducer<Text, IntWritable, Text, IntWritable>{ @Override protected void reduce(Text key3, Iterable<IntWritable> value3, Context context) throws IOException,InterruptedException{ int sum = 0; for (IntWritable value:value3) { sum += value.get(); } context.write(key3, new IntWritable(total)); } }

ExamMain类的main方法的程序实现(12分)： package MapReduceExam; import ... public class ExamMain { public static void main( String[] args) throws Exception { // 创建一个job作业实例 Job job = Job.getInstance (new Configuration()); // 设置作业的启动类 job.setJarByClass (ExamMain.class); // 设置Map的类和输入类型 job.setMapperClass(ExamMapper.class); job.setMapOutputKeyClass(Text.class); job.setMapOutputValueClass(IntWritable.class); // 设置reduce的类和输入类型 job.setReducerClass(ExamReducer.class); job.setOutputKeyClass(Text.class); job.setOutputValueClass (IntWritable.class); String path = "hdfs://192.168.44.128:9000/ExamData/"; FileInputFormat.setInputPaths(job,new Path(path +"personInfo.csv")); // 设置输出的唯一路径 FileOutputFormat.setOutputPath(job,new Path(path +"output")); // 执行job并等待处理过程结束 job.waitForCompletion( (true); } }

1