一、基类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@Overridepublic 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),可以免费白嫖