m0_58332232 2022-12-08 01:17 采纳率: 40%
浏览 97
已结题

mapreduce下的求和(运行成功,必采纳)急急急

问题:求震级>6的地震总数
要求:map reduce job分开写

img


以上部分数据代表时刻,震级,经度,纬度,深度,地区。

  • 写回答

4条回答 默认 最新

  • ShowMeAI 2022-12-08 10:39
    关注

    针对你的地震数据,我写的代码解决方案如下,望采纳:

    Map阶段代码:

    import java.io.IOException;
    
    import org.apache.hadoop.io.IntWritable;
    import org.apache.hadoop.io.LongWritable;
    import org.apache.hadoop.io.Text;
    import org.apache.hadoop.mapreduce.Mapper;
    
    public class EarthquakeMapper extends Mapper<LongWritable, Text, IntWritable, IntWritable> {
    
      private static final IntWritable ONE = new IntWritable(1);
    
      @Override
      public void map(LongWritable key, Text value, Context context) throws IOException, InterruptedException {
        // 解析地震数据
        String[] data = value.toString().split(",");
        float magnitude = Float.parseFloat(data[1]);
        // 如果震级大于6,输出(1,1)
        if (magnitude > 6) {
          context.write(ONE, ONE);
        }
      }
    }
    

    Reduce阶段代码:

    import java.io.IOException;
    
    import org.apache.hadoop.io.IntWritable;
    import org.apache.hadoop.mapreduce.Reducer;
    
    public class EarthquakeReducer extends Reducer<IntWritable, IntWritable, IntWritable, IntWritable> {
    
      @Override
      public void reduce(IntWritable key, Iterable<IntWritable> values, Context context)
          throws IOException, InterruptedException {
        // 计数器初始化为0
        int count = 0;
        // 遍历所有(1,1)的二元组,计数器加1
        for (IntWritable value : values) {
          count += value.get();
        }
        // 输出震级大于6的地震的总数
        context.write(key, new IntWritable(count));
      }
    }
    
    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(3条)

报告相同问题?

问题事件

  • 系统已结题 12月16日
  • 已采纳回答 12月8日
  • 创建了问题 12月8日

悬赏问题

  • ¥15 office打开卡退(新电脑重装office系统后)
  • ¥300 FLUENT 火箭发动机燃烧EDC仿真
  • ¥15 【Hadoop 问题】Hadoop编译所遇问题hadoop-common: make failed with error code 2
  • ¥15 vb6.0+webbrowser无法加载某个网页求解
  • ¥15 RPA财务机器人采购付款流程
  • ¥15 计算机图形多边形及三次样条曲线绘制
  • ¥15 根据protues画的图用keil写程序
  • ¥200 如何使用postGis实现最短领规划?
  • ¥15 pyinstaller打包错误
  • ¥20 cesm的气溶胶排放文件