ReduceJoin 案例 TableBean| 学习笔记

简介: 快速学习 ReduceJoin 案例 TableBean

开发者学堂课程【Hadoop 分布式计算框架 MapReduc:ReduceJoin 案例 TableBean学习笔记,与课程紧密联系,让用户快速学习知识。

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


ReduceJoin 案例 TableBean


代码示例

创建商品和订合并后的 Bean 类

package com.liun.mr.reducejoin;

 

import java.io.DataInput;

import java.io.DataOutput;

import java.io.IOException;

 

import org.apache.hadoop.io.Writable;

 

public class TableBean implements Writable{

 

private String order_id;

private String p_id;

private int amount;

private String pname;

private String flag;

public TableBean() {

super();

}

 

public TableBean(String order_id, String p_id, int amount, String pname, String flag) {

super();

this.order_id = order_id;

this.p_id = p_id;

this.amount = amount;

this.pname = pname;

this.flag = flag;

}

 

@Override

public void write(DataOutput out) throws IOException {

// 序列化

out.writeUTF(order_id);

out.writeUTF(p_id);

out.writeInt(amount);;

out.writeUTF(pname);

out.writeUTF(flag);

}

 

@Override

public void readFields(DataInput in) throws IOException {

// 反序列化

order_id = in.readUTF();

p_id = in.readUTF();

amount = in.readInt();

pname = in.readUTF();

flag = in.readUTF();

}

 

public String getOrder_id() {

return order_id;

}

 

public void setOrder_id(String order_id) {

this.order_id = order_id;

}

 

public String getP_id() {

return p_id;

}

 

public void setP_id(String p_id) {

this.p_id = p_id;

}

 

public int getAmount() {

return amount;

}

 

public void setAmount(int amount) {

this.amount = amount;

}

 

public String getPname() {

return pname;

}

 

public void setPname(String pname) {

this.pname = pname;

}

 

public String getFlag() {

return flag;

}

 

public void setFlag(String flag) {

this.flag = flag;

}

 

@Override

public String toString() {

return  order_id + "\t" + amount + "\t" + pname;

}

}


相关文章
|
SQL 分布式计算 MaxCompute
ODPS-0130161:Parse exception - line 1:0 cannot recognize input near 'setproject' 'odps'
ODPS-0130161:Parse exception - line 1:0 cannot recognize input near 'setproject' 'odps'
794 2
|
6月前
|
SQL 关系型数据库 MySQL
盘点6个SQL小技巧
这篇内容介绍了数据库查询中的各种JOIN操作,包括内联接(inner join)、左外联接(left outer join)、右外联接(right outer join)和全联接(full outer join)。其中,LEFT JOIN可以用于替换NOT EXISTS和NOT IN的查询。接着,文章展示了如何查询每个类别中的最高分记录,以及如何利用GROUP BY和LIMIT获取每个类别中的前N个记录。此外,还提到了MySQL 8引入的新语法LATERAL JOIN,用于更方便地处理这类问题。最后,文章提到了如何高效地统计不同时间范围内的数据量以及对比两个表之间的数据差异。
|
人工智能 达摩院 物联网
应用案例|学习笔记
快速学习应用案例
109 0
应用案例|学习笔记
|
SQL 安全 Java
案例介绍|学习笔记
快速学习案例介绍
案例介绍|学习笔记
|
开发者
案例_1|学习笔记
快速学习案例_1
案例_1|学习笔记
|
缓存 网络架构 开发者
案例_2|学习笔记
快速学习案例_2
案例_2|学习笔记
|
Kubernetes 安全 应用服务中间件
案例实战| 学习笔记
快速学习案例实战。
案例实战| 学习笔记
|
机器学习/深度学习 Kubernetes 安全
案例实战二| 学习笔记
快速学习案例实战二。
案例实战二| 学习笔记
|
SQL HIVE 开发者
SearchType 案例介绍|学习笔记
快速学习 SearchType 案例介绍。
|
JSON 算法 数据格式
SearchType 案例_介绍 | 学习笔记
快速学习 SearchType 案例_介绍