Use TimeStat addNanos where applicable

trinodb · Oct 26, 2022 · e2c1abd · e2c1abd
1 parent bc38622
commit e2c1abd
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 8 deletions.
diff --git a/plugin/trino-hive/src/main/java/io/trino/plugin/hive/aws/AwsApiCallStats.java b/plugin/trino-hive/src/main/java/io/trino/plugin/hive/aws/AwsApiCallStats.java
@@ -56,9 +56,9 @@ public CounterStat getTotalFailures()
         return totalFailures;
     }
 
-    public void recordCall(long executionTimeInMillis, boolean failure)
+    public void recordCall(long executionTimeNanos, boolean failure)
     {
-        time.add(executionTimeInMillis, MILLISECONDS);
+        time.addNanos(executionTimeNanos);
         if (failure) {
             totalFailures.update(1);
         }

diff --git a/plugin/trino-hive/src/main/java/io/trino/plugin/hive/aws/AwsSdkClientCoreStats.java b/plugin/trino-hive/src/main/java/io/trino/plugin/hive/aws/AwsSdkClientCoreStats.java
@@ -173,9 +173,9 @@ private static void recordSubTimingDurations(TimingInfo timingInfo, AWSRequestMe
             List<TimingInfo> subTimings = timingInfo.getAllSubMeasurements(field.name());
             if (subTimings != null) {
                 for (TimingInfo subTiming : subTimings) {
-                    Double millis = subTiming.getTimeTakenMillisIfKnown();
-                    if (millis != null) {
-                        timeStat.add(millis, MILLISECONDS);
+                    Long endTimeNanos = subTiming.getEndTimeNanoIfKnown();
+                    if (endTimeNanos != null) {
+                        timeStat.addNanos(endTimeNanos - subTiming.getStartTimeNano());
                     }
                 }
             }

diff --git a/plugin/trino-hive/src/main/java/io/trino/plugin/hive/metastore/glue/GlueHiveMetastore.java b/plugin/trino-hive/src/main/java/io/trino/plugin/hive/metastore/glue/GlueHiveMetastore.java
@@ -147,7 +147,7 @@
 import static io.trino.spi.StandardErrorCode.NOT_SUPPORTED;
 import static io.trino.spi.security.PrincipalType.USER;
 import static java.util.Objects.requireNonNull;
-import static java.util.concurrent.TimeUnit.MILLISECONDS;
+import static java.util.concurrent.TimeUnit.NANOSECONDS;
 import static java.util.function.Predicate.not;
 import static java.util.function.UnaryOperator.identity;
 import static java.util.stream.Collectors.toCollection;
@@ -1141,13 +1141,13 @@ public StatsRecordingAsyncHandler(AwsApiCallStats stats)
         @Override
         public void onError(Exception e)
         {
-            stats.recordCall(stopwatch.elapsed(MILLISECONDS), true);
+            stats.recordCall(stopwatch.elapsed(NANOSECONDS), true);
         }
 
         @Override
         public void onSuccess(AmazonWebServiceRequest request, Object o)
         {
-            stats.recordCall(stopwatch.elapsed(MILLISECONDS), false);
+            stats.recordCall(stopwatch.elapsed(NANOSECONDS), false);
         }
     }
 }