in src/main/java/software/amazon/qldb/ResultRetriever.java [225:258]
void updateMetrics(FetchPageResult fetchPageResult) {
software.amazon.awssdk.services.qldbsession.model.IOUsage ioUsage = fetchPageResult.consumedIOs();
if (ioUsage != null) {
final Long readIOs = ioUsage.readIOs();
if (readIOs != null) {
if (accumulatedReadIOs == null) {
accumulatedReadIOs = readIOs;
} else {
accumulatedReadIOs += readIOs;
}
}
final Long writeIOs = ioUsage.writeIOs();
if (writeIOs != null) {
if (accumulatedWriteIOs == null) {
accumulatedWriteIOs = writeIOs;
} else {
accumulatedWriteIOs += writeIOs;
}
}
}
software.amazon.awssdk.services.qldbsession.model.TimingInformation timingInfo = fetchPageResult.timingInformation();
if (timingInfo != null) {
final Long processingTimeMilliseconds = timingInfo.processingTimeMilliseconds();
if (processingTimeMilliseconds != null) {
if (accumulatedProcessingTimeMilliseconds == null) {
accumulatedProcessingTimeMilliseconds = processingTimeMilliseconds;
} else {
accumulatedProcessingTimeMilliseconds += processingTimeMilliseconds;
}
}
}
}