From c48c8b672e293f97416c715096a4d35e911ef81f Mon Sep 17 00:00:00 2001 From: Piotr Findeisen Date: Mon, 4 Feb 2019 10:40:06 +0100 Subject: [PATCH] Remove incorrect getReadTimeNanos() implementations --- .../plugin/accumulo/io/AccumuloRecordCursor.java | 9 +-------- .../java/io/prestosql/plugin/kudu/KuduRecordCursor.java | 6 +----- 2 files changed, 2 insertions(+), 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 index b8910fe2d2490..4d9f9d37f51cb 100644 --- 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 index c48ad1399b18b..bcd97c6b5c6e6 100755 --- 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 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; }