void updateMetrics()

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;
                    }
                }
            }
        }