分组排序案例扩展| 学习笔记

简介: 快速学习分组排序案例扩展

开发者学堂课程【Hadoop 分布式计算框架 MapReduce:分组排序案例扩展】学习笔记,与课程紧密联系,让用户快速学习知识。

课程地址:https://developer.aliyun.com/learning/course/94/detail/1535


分组排序案例扩展


下面的代码案例表示的只输出了最贵的一个价格

package com.atguigu.mr.order;import java.io.IOException;

public class OrderReducer extends Reducer<OrderBean,Nullwritable,OrderBean,Nullwritab>{

@Override

protected void reduce(OrderBean key,Iterable<Nullwritable> values,Context context)

throws IOException,InterruptedException {

context.write(key,Nullwritable.get());

}

}

但如果我们想要输出前三名的话,只需要最后两行代码中,输入 for(NullWritable nullWritable :values) ,由此来记住循环的次数,如下:

图片21.png

之后再回到 OrderDiver 类中,将 output4 变成 output5,

图片22.png

运行查看结果,就得到了我们所要的最高的三个值,基于该代码有所难度,同学们课后多度思考

图片23.png

相关文章
|
监控 网络协议 Linux
在Linux中,如何实时抓取并显示当前系统中tcp 80 端口的网络数据信息?
在Linux中,如何实时抓取并显示当前系统中tcp 80 端口的网络数据信息?
|
存储 Java
Java锁是什么?简单了解
在高并发环境下,锁是Java中至关重要的概念。锁或互斥是一种同步机制,用于限制多线程环境下的资源访问,确保排他性和并发控制。例如,超市储物柜仅能存放一个物品,若三人同时使用,则需通过锁机制确保每次只有一个线程访问。Java中可以通过`synchronized`关键字实现加锁,确保关键代码段的原子性,避免数据不一致问题。正确使用锁可有效提升程序的稳定性和安全性。
256 1
Java锁是什么?简单了解
|
供应链 物联网 区块链
未来已来:新兴技术的融合与革新
【8月更文挑战第17天】随着科技的不断进步,新技术如区块链、物联网(IoT)、虚拟现实(VR)等正逐渐渗透到我们生活的方方面面。这些技术不仅改变了我们的生活方式,还预示着一个更加智能、互联的未来。本文章将深入探讨这些技术的发展趋势及其在现实世界中的应用案例,揭示它们如何共同塑造我们的未来。
93 1
|
SQL Java 数据库连接
使用Python通过JDBC操作数据库(达梦数据库)
使用Python通过JDBC操作数据库(达梦数据库)
1693 0
|
JSON JavaScript 前端开发
超详细的JavaScript深拷贝实现
超详细的JavaScript深拷贝实现
341 0
超详细的JavaScript深拷贝实现
|
安全 网络协议 网络安全
网络扫描与网络监听
网络扫描与网络监听
367 0
|
JavaScript
JS 刷 Leetcode:026. 删除有序数组中的重复项
JS 刷 Leetcode:026. 删除有序数组中的重复项
JS 刷 Leetcode:026. 删除有序数组中的重复项
|
存储 安全 算法
史上最全的Java容器集合之ConcurrentHashMap(源码解读)(下)
前言 文本已收录至我的GitHub仓库,欢迎Star:github.com/bin39232820… 种一棵树最好的时间是十年前,其次是现在
189 0
|
SQL 缓存 网络协议
MySQL架构与SQL的执行流程_1
MySQL架构与SQL的执行流程_1
190 0
MySQL架构与SQL的执行流程_1