in adb3client/src/main/java/com/alibaba/cloud/analyticdb/adb3client/AdbClient.java [240:266]
public void put(List<Put> puts) throws AdbClientException {
ensurePoolOpen();
tryThrowException();
AdbClientWithDetailsException detailException = null;
List<Put> putList = new ArrayList<>();
for (Put put : puts) {
try {
checkPut(put);
putList.add(put);
} catch (AdbClientWithDetailsException e) {
if (detailException == null) {
detailException = e;
} else {
detailException.merge(e);
}
}
}
for (Put put : putList) {
collector.append(put.getRecord());
}
if (!asyncCommit) {
collector.flush(false);
}
if (detailException != null) {
throw detailException;
}
}