in adb3client/src/main/java/com/alibaba/cloud/analyticdb/adb3client/model/Record.java [238:260]
public void merge(Record record) {
if (!schema.equals(record.schema)) {
throw new InvalidParameterException("schema not match");
}
for (int i = 0; i < record.getSize(); ++i) {
if (record.isSet(i) && !record.getOnlyInsertColumnSet().get(i)) {
setObject(i, record.getObject(i));
}
}
//merge attachment
this.addAttachmentList(record.attachmentList);
//merge putFutures
if (putFutures == null) {
if (record.putFutures != null) {
this.putFutures = new ArrayList<>(record.putFutures);
}
} else {
if (record.putFutures != null) {
this.putFutures.addAll(record.putFutures);
}
}
}