大数据全系列 教程
1869个小节阅读:465.9k
目录
408考研
JAVA全系列 教程
面向对象的程序设计语言
Python全系列 教程
Python3.x版本,未来主流的版本
人工智能 教程
顺势而为,AI创新未来
大厂算法 教程
算法,程序员自我提升必经之路
C++ 教程
一门通用计算机编程语言
微服务 教程
目前业界流行的框架组合
web前端全系列 教程
通向WEB技术世界的钥匙
大数据全系列 教程
站在云端操控万千数据
AIGC全能工具班
A A
White Night
xxxxxxxxxx
package cn.itbaizhan.tranformer.model;
import cn.itbaizhan.common.KpiType;
import org.apache.hadoop.io.MapWritable;
import org.apache.hadoop.io.WritableUtils;
import java.io.DataInput;
import java.io.DataOutput;
import java.io.IOException;
/**Reducer类输出value对象类型的类
*/
public class MapWritableValue extends BaseStatsValueWritable{
//Reducer输出要写入mysql的表中,那么就存在以下两个问题:
//1.把数据写入到哪个表中?比如new_install_user->query-mapping.xml中找name为new_install_user插入sql语句
private KpiType kpi;
//2.对应表中一行记录的数据内容
private MapWritable value = new MapWritable();
public MapWritableValue() {
super();
}
public MapWritableValue(KpiType kpi, MapWritable value) {
super();
this.kpi = kpi;
this.value = value;
}
@Override
public KpiType getKpi() {
return this.kpi;
}
@Override
public void write(DataOutput out) throws IOException {
this.value.write(out);
WritableUtils.writeEnum(out,this.kpi);
}
@Override
public void readFields(DataInput in) throws IOException {
this.value.readFields(in);
this.kpi = WritableUtils.readEnum(in,KpiType.class);
}
public void setKpi(KpiType kpi) {
this.kpi = kpi;
}
public MapWritable getValue() {
return value;
}
public void setValue(MapWritable value) {
this.value = value;
}
}