码迷,mamicode.com
首页 > 编程语言 > 详细

MapReduce自定义排序器不生效一个可能的原因

时间:2019-05-18 00:31:20      阅读:165      评论:0      收藏:0      [点我收藏+]

标签:排序   类型   --   参数   san   ado   new   nbsp   tor   

有问题的代码:

package com.mytq.weather;
import org.apache.hadoop.io.WritableComparable; import org.apache.hadoop.io.WritableComparator; public class WSortComparator extends WritableComparator { public WSortComparator() { super(Weather.class, true); }
@Override
public int compare(Object a, Object b) { //使用object会有问题 Weather t1 = (Weather)a; Weather t2 = (Weather)b; int c1 = Integer.compare(t1.getYear(), t2.getYear()); if (c1 == 0) { int c2 = Integer.compare(t1.getMonth(), t2.getMonth()); if (c2==0) { return -Integer.compare(t1.getWd(), t2.getWd()); // 温度倒序排列 } return
return c1; } }

需要将compare两个参数的类型由object修改为WritableComparable才行。

 

----------------

在源码中暂时没找到调用逻辑┓( ´∀` )┏

MapReduce自定义排序器不生效一个可能的原因

标签:排序   类型   --   参数   san   ado   new   nbsp   tor   

原文地址:https://www.cnblogs.com/144823836yj/p/10884227.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!