概述
一、基类Column概述
Column是datax中所有数据类型的基类,里面有3个属性,以及一个构造方法,外加一个枚举类;
public abstract class Column {
private Type type;
private Object rawData;
private int byteSize;
public Column(final Object object, final Type type, int byteSize) {
this.rawData = object;
this.type = type;
this.byteSize = byteSize;
}
//省去其他非关键方法
public enum Type {
BAD, NULL, INT, LONG, DOUBLE, STRING, BOOL, DATE, BYTES
}
}
二、Column衍生出的类型对象
一个爷爷衍生出的7个金刚葫芦娃
三、用Column及其子类构建出的记录对象Record
Record家族系列(一般情况下DefaultRecord使用较多)
可以通过idea的全局搜索 record.addColumn
方法,看看各个读插件是怎么转成Datax内部Column的。具体方法在Record中
基类Record
/**
* 给该record 添加列
*
* @param column
*/
void addColumn(Column column);
实现类DefaultRecord
@Override
public void addColumn(Column column) {
columns.add(column);
incrByteSize(column);
}
四、创建Record的RecordSender类
RecordSender主要方法
RecordSender家族类
RecordSender主要通过createRecord来构建一个Record
五、RecordSender,Record,Column关系总结
1、RecordSender中Record createRecord() 可以创建一个Record
2、Record中void addColumn(Column column)可以将column添加到该记录中
注:
-
对源码进行略微改动,主要修改为 1 阿里代码规约扫描出来的,2 clean code;
-
所有代码都已经上传到github(master分支和dev),可以免费白嫖
最后
以上就是单薄哈密瓜为你收集整理的datax(13):源码解读Column-datax中的数据类型的全部内容,希望文章能够帮你解决datax(13):源码解读Column-datax中的数据类型所遇到的程序开发问题。
如果觉得靠谱客网站的内容还不错,欢迎将靠谱客网站推荐给程序员好友。
本图文内容来源于网友提供,作为学习参考使用,或来自网络收集整理,版权属于原作者所有。
发表评论 取消回复