diff --git a/plugin/trino-cassandra/src/main/java/io/trino/plugin/cassandra/CassandraRecordCursor.java b/plugin/trino-cassandra/src/main/java/io/trino/plugin/cassandra/CassandraRecordCursor.java index f70b5c590148..d4d30102d153 100644 --- a/plugin/trino-cassandra/src/main/java/io/trino/plugin/cassandra/CassandraRecordCursor.java +++ b/plugin/trino-cassandra/src/main/java/io/trino/plugin/cassandra/CassandraRecordCursor.java @@ -34,7 +34,6 @@ public class CassandraRecordCursor private final List cassandraTypes; private final ResultSet rs; private Row currentRow; - private long count; public CassandraRecordCursor(CassandraSession cassandraSession, List cassandraTypes, String cql) { @@ -48,7 +47,6 @@ public boolean advanceNextPosition() { if (!rs.isExhausted()) { currentRow = rs.one(); - count++; return true; } return false; @@ -68,7 +66,7 @@ public boolean getBoolean(int i) @Override public long getCompletedBytes() { - return count; + return 0; } @Override