大家好,又见面了,我是你们的朋友全栈君。
一、基类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),可以免费白嫖
发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/145406.html原文链接:https://javaforall.cn
【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛
【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...