大数据全系列 教程
1869个小节阅读:467.8k
目录
408考研
JAVA全系列 教程
面向对象的程序设计语言
Python全系列 教程
Python3.x版本,未来主流的版本
人工智能 教程
顺势而为,AI创新未来
大厂算法 教程
算法,程序员自我提升必经之路
C++ 教程
一门通用计算机编程语言
微服务 教程
目前业界流行的框架组合
web前端全系列 教程
通向WEB技术世界的钥匙
大数据全系列 教程
站在云端操控万千数据
AIGC全能工具班
A A
White Night
比较器类型 | MapTask | ReduceTask |
---|---|---|
分组比较器 | 用户自定义 | |
排序比较 | 用户自定义 | 用户自定义 |
自带比较器 | key自带 | key自带 |
如何设置分组比较器?
xxxxxxxxxx
job.setGroupingComparatorClass(WCGroupingComparator.class);
设置分组比较器底层代码:
xxxxxxxxxx
public void setGroupingComparatorClass(Class<? extends RawComparator> cls
) throws IllegalStateException {
ensureState(JobState.DEFINE);
conf.setOutputValueGroupingComparator(cls);
}
setOutputValueGroupingComparator():
xxxxxxxxxx
public void setOutputValueGroupingComparator(
Class<? extends RawComparator> theClass) {
setClass(JobContext.GROUP_COMPARATOR_CLASS,
theClass, RawComparator.class);
}
JobContext.GROUP_COMPARATOR_CLASS就和获取使用使用的同一个常量。