首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >专栏 >MapReduce当中排序sort的方法

MapReduce当中排序sort的方法

作者头像
马克java社区
修改2021-07-05 10:22:15
修改2021-07-05 10:22:15
4340
举报
文章被收录于专栏:java大数据java大数据

排序sort:

马克-to-win @ 马克java社区:防盗版实名手机尾号:73203。注意:想自己实现Sort得不偿失,但如想借助Hadoop MapReduce技术框架排序,key必须实现WritableComparable接口。具体做法见下。需求是先按id比,再按amount比。

package com;

import org.apache.hadoop.io.WritableComparable;

import java.io.DataInput;

import java.io.DataOutput;

import java.io.IOException;

public class OrderBeanSort implements WritableComparable<OrderBeanSort>{

private String orderId;

private Double amount;

private Double average=0.0;

public Double getAverage() {

return average;

}

public void setAverage(Double average) {

this.average = average;

}

public OrderBeanSort() {

}

public OrderBeanSort(String orderId, Double amount) {

this.orderId = orderId;

this.amount = amount;

}

public void set(String orderId, Double amount) {

this.orderId = orderId;

this.amount = amount;

}

public String getOrderId() {

return orderId;

}

public void setOrderId(String orderId) {

this.orderId = orderId;

}

public Double getAmount() {

return amount;

}

public void setAmount(Double amount) {

this.amount = amount;

}

public void write(DataOutput out) throws IOException {

out.writeUTF(orderId);

out.writeDouble(amount);

out.writeDouble(average);

}

更多请见:https://blog.csdn.net/qq_44594249/article/details/97236398

本文系转载,前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文系转载前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档