commit 64a8afcf0cc89b618e7c3ce889b84208c38d3047
author Charles S. Givre <cgivre@apache.org> Sun Oct 23 08:46:30 2022 -0400
committer GitHub <noreply@github.com> Sun Oct 23 08:46:30 2022 -0400
tree 16046ec409cb41bdac0410a0c79370aba30a2ef3
parent 243e539de50b57c14cb136b5e7fb30a6583f1732

DRILL-8341: Add Scanned Plugin List to Sys Profiles Table (#2690)

exec/java-exec/src/main/java/org/apache/drill/exec/store/sys/ProfileInfoIterator.java

diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/sys/ProfileInfoIterator.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/sys/ProfileInfoIterator.java
index f068915..a5a01aa 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/sys/ProfileInfoIterator.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/sys/ProfileInfoIterator.java
@@ -90,6 +90,8 @@
             computeDuration(profile.getPlanEnd(), assumedQueueEndTime),
             computeDuration(assumedQueueEndTime, profile.getEnd()),
             profile.getState().name(),
+            profile.getScannedPluginsCount(),
+            profile.getScannedPluginsList().toString(),
             profile.getQuery()
          );
       }
@@ -129,11 +131,13 @@
     public final long executeTime;
     public final long totalTime;
     public final String state;
+    public final long pluginCount;
+    public final String pluginList;
     public final String query;
 
     public ProfileInfo(String query_id, Timestamp time, String foreman, long fragmentCount, String username,
         String queueName, long planDuration, long queueWaitDuration, long executeDuration,
-        String state, String query) {
+        String state, long pluginCount, String pluginList, String query) {
       this.queryId = query_id;
       this.startTime = time;
       this.foreman = foreman;
@@ -145,13 +149,15 @@
       this.executeTime = executeDuration;
       this.totalTime = this.planTime + this.queueTime + this.executeTime;
       this.query = query;
+      this.pluginCount = pluginCount;
+      this.pluginList = pluginList;
       this.state = state;
     }
 
     private ProfileInfo() {
       this(UNKNOWN_VALUE, new Timestamp(0), UNKNOWN_VALUE, 0L,
           UNKNOWN_VALUE, UNKNOWN_VALUE, 0L, 0L,
-          0L, UNKNOWN_VALUE, UNKNOWN_VALUE);
+          0L, UNKNOWN_VALUE, 0L, UNKNOWN_VALUE, UNKNOWN_VALUE);
     }
 
     /**

exec/java-exec/src/test/java/org/apache/drill/exec/work/metadata/TestMetadataProvider.java

diff --git a/exec/java-exec/src/test/java/org/apache/drill/exec/work/metadata/TestMetadataProvider.java b/exec/java-exec/src/test/java/org/apache/drill/exec/work/metadata/TestMetadataProvider.java
index d85b784..c0c742a 100644
--- a/exec/java-exec/src/test/java/org/apache/drill/exec/work/metadata/TestMetadataProvider.java
+++ b/exec/java-exec/src/test/java/org/apache/drill/exec/work/metadata/TestMetadataProvider.java
@@ -242,7 +242,7 @@
 
     assertEquals(RequestStatus.OK, resp.getStatus());
     List<ColumnMetadata> columns = resp.getColumnsList();
-    assertEquals(170, columns.size());
+    assertEquals(172, columns.size());
     // too many records to verify the output.
   }