Remove incorrect getReadTimeNanos() implementations

trinodb · Feb 5, 2019 · c48c8b6 · c48c8b6
1 parent c3675ee
commit c48c8b6
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 13 deletions.
diff --git a/presto-accumulo/src/main/java/io/prestosql/plugin/accumulo/io/AccumuloRecordCursor.java b/presto-accumulo/src/main/java/io/prestosql/plugin/accumulo/io/AccumuloRecordCursor.java
@@ -75,8 +75,6 @@ public class AccumuloRecordCursor
     private final AccumuloRowSerializer serializer;
 
     private long bytesRead;
-    private long nanoStart;
-    private long nanoEnd;
 
     public AccumuloRecordCursor(
             AccumuloRowSerializer serializer,
@@ -147,7 +145,7 @@ public long getCompletedBytes()
     @Override
     public long getReadTimeNanos()
     {
-        return nanoStart > 0L ? (nanoEnd == 0 ? System.nanoTime() : nanoEnd) - nanoStart : 0L;
+        return 0;
     }
 
     @Override
@@ -160,10 +158,6 @@ public Type getType(int field)
     @Override
     public boolean advanceNextPosition()
     {
-        if (nanoStart == 0) {
-            nanoStart = System.nanoTime();
-        }
-
         try {
             if (iterator.hasNext()) {
                 serializer.reset();
@@ -270,7 +264,6 @@ else if (type instanceof VarcharType) {
     public void close()
     {
         scanner.close();
-        nanoEnd = System.nanoTime();
     }
 
     /**

diff --git a/presto-kudu/src/main/java/io/prestosql/plugin/kudu/KuduRecordCursor.java b/presto-kudu/src/main/java/io/prestosql/plugin/kudu/KuduRecordCursor.java
@@ -37,8 +37,6 @@ public class KuduRecordCursor
     protected RowResult currentRow;
 
     private long totalBytes;
-    private long nanoStart;
-    private long nanoEnd;
     private boolean started;
 
     public KuduRecordCursor(KuduScanner scanner, List<Type> columnTypes)
@@ -65,7 +63,7 @@ public long getCompletedBytes()
     @Override
     public long getReadTimeNanos()
     {
-        return nanoStart > 0L ? (nanoEnd == 0 ? System.nanoTime() : nanoEnd) - nanoStart : 0L;
+        return 0;
     }
 
     @Override
@@ -89,7 +87,6 @@ public boolean advanceNextPosition()
 
         if (!started) {
             started = true;
-            nanoStart = System.nanoTime();
         }
 
         if (needNextRows) {
@@ -186,7 +183,6 @@ public boolean isNull(int field)
     @Override
     public void close()
     {
-        nanoEnd = System.nanoTime();
         currentRow = null;
         nextRows = null;
     }