Add debug log for Cassandra query

trinodb · Jul 22, 2020 · a6e01fc · a6e01fc
1 parent e533c3a
commit a6e01fc
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/presto-cassandra/src/main/java/io/prestosql/plugin/cassandra/CassandraSession.java b/presto-cassandra/src/main/java/io/prestosql/plugin/cassandra/CassandraSession.java
@@ -428,11 +428,13 @@ public List<CassandraPartition> getPartitions(CassandraTable table, List<Set<Obj
 
     public ResultSet execute(String cql)
     {
+        log.debug("Execute cql: %s", cql);
         return executeWithSession(session -> session.execute(cql));
     }
 
     public PreparedStatement prepare(RegularStatement statement)
     {
+        log.debug("Execute RegularStatement: %s", statement);
         return executeWithSession(session -> session.prepare(statement));
     }
 
@@ -449,6 +451,7 @@ private Iterable<Row> queryPartitionKeysWithInClauses(CassandraTable table, List
         Select partitionKeys = selectDistinctFrom(tableHandle, partitionKeyColumns);
         addWhereInClauses(partitionKeys.where(), partitionKeyColumns, filterPrefixes);
 
+        log.debug("Execute cql for partition keys with IN clauses: %s", partitionKeys);
         return execute(partitionKeys).all();
     }
 
@@ -464,6 +467,7 @@ private Iterable<Row> queryPartitionKeysLegacyWithMultipleQueries(CassandraTable
             Select partitionKeys = selectDistinctFrom(tableHandle, partitionKeyColumns);
             addWhereClause(partitionKeys.where(), partitionKeyColumns, combination);
 
+            log.debug("Execute cql for partition keys with multiple queries: %s", partitionKeys);
             List<Row> resultRows = execute(partitionKeys).all();
             if (resultRows != null && !resultRows.isEmpty()) {
                 rowList.addAll(resultRows);