code fix

Author: anandamideShakyan

presto-main-base/src/main/java/com/facebook/presto/execution/BasicStageExecutionStats.java

@@ -68,10 +68,10 @@ public class BasicStageExecutionStats
     private final int queuedDrivers;
     private final int runningDrivers;
     private final int completedDrivers;
-    private final int totalNewDrivers;
-    private final int queuedNewDrivers;
-    private final int runningNewDrivers;
-    private final int completedNewDrivers;
+    private final int totalNativeDrivers;
+    private final int queuedNativeDrivers;
+    private final int runningNativeDrivers;
+    private final int completedNativeDrivers;
     private final int totalSplits;
     private final int queuedSplits;
     private final int runningSplits;
@@ -97,10 +97,10 @@ public BasicStageExecutionStats(
             int runningDrivers,
             int completedDrivers,
 
-            int totalNewDrivers,
-            int queuedNewDrivers,
-            int runningNewDrivers,
-            int completedNewDrivers,
+            int totalNativeDrivers,
+            int queuedNativeDrivers,
+            int runningNativeDrivers,
+            int completedNativeDrivers,
 
             int totalSplits,
             int queuedSplits,
@@ -130,10 +130,10 @@ public BasicStageExecutionStats(
         this.queuedDrivers = queuedDrivers;
         this.runningDrivers = runningDrivers;
         this.completedDrivers = completedDrivers;
-        this.totalNewDrivers = totalNewDrivers;
-        this.queuedNewDrivers = queuedNewDrivers;
-        this.runningNewDrivers = runningNewDrivers;
-        this.completedNewDrivers = completedNewDrivers;
+        this.totalNativeDrivers = totalNativeDrivers;
+        this.queuedNativeDrivers = queuedNativeDrivers;
+        this.runningNativeDrivers = runningNativeDrivers;
+        this.completedNativeDrivers = completedNativeDrivers;
         this.totalSplits = totalSplits;
         this.queuedSplits = queuedSplits;
         this.runningSplits = runningSplits;
@@ -181,24 +181,24 @@ public int getCompletedDrivers()
         return completedDrivers;
     }
 
-    public int getTotalNewDrivers()
+    public int getTotalNativeDrivers()
     {
-        return totalNewDrivers;
+        return totalNativeDrivers;
     }
 
-    public int getQueuedNewDrivers()
+    public int getQueuedNativeDrivers()
     {
-        return queuedNewDrivers;
+        return queuedNativeDrivers;
     }
 
-    public int getRunningNewDrivers()
+    public int getRunningNativeDrivers()
     {
-        return runningNewDrivers;
+        return runningNativeDrivers;
     }
 
-    public int getCompletedNewDrivers()
+    public int getCompletedNativeDrivers()
     {
-        return completedNewDrivers;
+        return completedNativeDrivers;
     }
 
     public int getTotalSplits()
@@ -288,10 +288,10 @@ public static BasicStageExecutionStats aggregateBasicStageStats(Iterable<BasicSt
         int runningDrivers = 0;
         int completedDrivers = 0;
 
-        int totalNewDrivers = 0;
-        int queuedNewDrivers = 0;
-        int runningNewDrivers = 0;
-        int completedNewDrivers = 0;
+        int totalNativeDrivers = 0;
+        int queuedNativeDrivers = 0;
+        int runningNativeDrivers = 0;
+        int completedNativeDrivers = 0;
 
         int totalSplits = 0;
         int queuedSplits = 0;
@@ -322,10 +322,10 @@ public static BasicStageExecutionStats aggregateBasicStageStats(Iterable<BasicSt
             runningDrivers += stageStats.getRunningDrivers();
             completedDrivers += stageStats.getCompletedDrivers();
 
-            totalNewDrivers += stageStats.getTotalNewDrivers();
-            queuedNewDrivers += stageStats.getQueuedNewDrivers();
-            runningNewDrivers += stageStats.getRunningNewDrivers();
-            completedNewDrivers += stageStats.getCompletedNewDrivers();
+            totalNativeDrivers += stageStats.getTotalNativeDrivers();
+            queuedNativeDrivers += stageStats.getQueuedNativeDrivers();
+            runningNativeDrivers += stageStats.getRunningNativeDrivers();
+            completedNativeDrivers += stageStats.getCompletedNativeDrivers();
 
             totalSplits += stageStats.getTotalSplits();
             queuedSplits += stageStats.getQueuedSplits();
@@ -364,10 +364,10 @@ public static BasicStageExecutionStats aggregateBasicStageStats(Iterable<BasicSt
                 runningDrivers,
                 completedDrivers,
 
-                totalNewDrivers,
-                queuedNewDrivers,
-                runningNewDrivers,
-                completedNewDrivers,
+                totalNativeDrivers,
+                queuedNativeDrivers,
+                runningNativeDrivers,
+                completedNativeDrivers,
 
                 totalSplits,
                 queuedSplits,

presto-main-base/src/main/java/com/facebook/presto/execution/QueryStateMachine.java

@@ -388,10 +388,10 @@ public BasicQueryInfo getBasicQueryInfo(Optional<BasicStageExecutionStats> rootS
                 stageStats.getRunningDrivers(),
                 stageStats.getCompletedDrivers(),
 
-                stageStats.getTotalNewDrivers(),
-                stageStats.getQueuedNewDrivers(),
-                stageStats.getRunningNewDrivers(),
-                stageStats.getCompletedNewDrivers(),
+                stageStats.getTotalNativeDrivers(),
+                stageStats.getQueuedNativeDrivers(),
+                stageStats.getRunningNativeDrivers(),
+                stageStats.getCompletedNativeDrivers(),
 
                 stageStats.getTotalSplits(),
                 stageStats.getQueuedSplits(),
@@ -1312,10 +1312,10 @@ private static QueryStats pruneQueryStats(QueryStats queryStats)
                 queryStats.getRunningDrivers(),
                 queryStats.getBlockedDrivers(),
                 queryStats.getCompletedDrivers(),
-                queryStats.getTotalNewDrivers(),
-                queryStats.getQueuedNewDrivers(),
-                queryStats.getRunningNewDrivers(),
-                queryStats.getCompletedNewDrivers(),
+                queryStats.getTotalNativeDrivers(),
+                queryStats.getQueuedNativeDrivers(),
+                queryStats.getRunningNativeDrivers(),
+                queryStats.getCompletedNativeDrivers(),
                 queryStats.getTotalSplits(),
                 queryStats.getQueuedSplits(),
                 queryStats.getRunningSplits(),

presto-main-base/src/main/java/com/facebook/presto/execution/QueryStats.java

@@ -78,10 +78,10 @@ public class QueryStats
     private final int blockedDrivers;
     private final int completedDrivers;
 
-    private final int totalNewDrivers;
-    private final int queuedNewDrivers;
-    private final int runningNewDrivers;
-    private final int completedNewDrivers;
+    private final int totalNativeDrivers;
+    private final int queuedNativeDrivers;
+    private final int runningNativeDrivers;
+    private final int completedNativeDrivers;
 
     private final int totalSplits;
     private final int queuedSplits;
@@ -162,10 +162,10 @@ public QueryStats(
             int blockedDrivers,
             int completedDrivers,
 
-            int totalNewDrivers,
-            int queuedNewDrivers,
-            int runningNewDrivers,
-            int completedNewDrivers,
+            int totalNativeDrivers,
+            int queuedNativeDrivers,
+            int runningNativeDrivers,
+            int completedNativeDrivers,
 
             int totalSplits,
             int queuedSplits,
@@ -254,14 +254,14 @@ public QueryStats(
         this.blockedDrivers = blockedDrivers;
         checkArgument(completedDrivers >= 0, "completedDrivers is negative");
         this.completedDrivers = completedDrivers;
-        checkArgument(totalNewDrivers >= 0, "totalNewDrivers is negative");
-        this.totalNewDrivers = totalNewDrivers;
-        checkArgument(queuedNewDrivers >= 0, "queuedNewDrivers is negative");
-        this.queuedNewDrivers = queuedNewDrivers;
-        checkArgument(runningNewDrivers >= 0, "runningNewDrivers is negative");
-        this.runningNewDrivers = runningNewDrivers;
-        checkArgument(completedNewDrivers >= 0, "completedNewDrivers is negative");
-        this.completedNewDrivers = completedNewDrivers;
+        checkArgument(totalNativeDrivers >= 0, "totalNativeDrivers is negative");
+        this.totalNativeDrivers = totalNativeDrivers;
+        checkArgument(queuedNativeDrivers >= 0, "queuedNativeDrivers is negative");
+        this.queuedNativeDrivers = queuedNativeDrivers;
+        checkArgument(runningNativeDrivers >= 0, "runningNativeDrivers is negative");
+        this.runningNativeDrivers = runningNativeDrivers;
+        checkArgument(completedNativeDrivers >= 0, "completedNativeDrivers is negative");
+        this.completedNativeDrivers = completedNativeDrivers;
         checkArgument(totalSplits >= 0, "totalSplits is negative");
         this.totalSplits = totalSplits;
         checkArgument(queuedSplits >= 0, "queuedSplits is negative");
@@ -350,10 +350,10 @@ public QueryStats(
             @JsonProperty("blockedDrivers") int blockedDrivers,
             @JsonProperty("completedDrivers") int completedDrivers,
 
-            @JsonProperty("totalNewDrivers") int totalNewDrivers,
-            @JsonProperty("queuedNewDrivers") int queuedNewDrivers,
-            @JsonProperty("runningNewDrivers") int runningNewDrivers,
-            @JsonProperty("completedNewDrivers") int completedNewDrivers,
+            @JsonProperty("totalNativeDrivers") int totalNativeDrivers,
+            @JsonProperty("queuedNativeDrivers") int queuedNativeDrivers,
+            @JsonProperty("runningNativeDrivers") int runningNativeDrivers,
+            @JsonProperty("completedNativeDrivers") int completedNativeDrivers,
 
             @JsonProperty("totalSplits") int totalSplits,
             @JsonProperty("queuedSplits") int queuedSplits,
@@ -432,10 +432,10 @@ public QueryStats(
                 blockedDrivers,
                 completedDrivers,
 
-                totalNewDrivers,
-                queuedNewDrivers,
-                runningNewDrivers,
-                completedNewDrivers,
+                totalNativeDrivers,
+                queuedNativeDrivers,
+                runningNativeDrivers,
+                completedNativeDrivers,
 
                 totalSplits,
                 queuedSplits,
@@ -508,10 +508,10 @@ public static QueryStats create(
         int blockedDrivers = 0;
         int completedDrivers = 0;
 
-        int totalNewDrivers = 0;
-        int queuedNewDrivers = 0;
-        int runningNewDrivers = 0;
-        int completedNewDrivers = 0;
+        int totalNativeDrivers = 0;
+        int queuedNativeDrivers = 0;
+        int runningNativeDrivers = 0;
+        int completedNativeDrivers = 0;
 
         int totalSplits = 0;
         int queuedSplits = 0;
@@ -567,10 +567,10 @@ public static QueryStats create(
             blockedDrivers += stageExecutionStats.getBlockedDrivers();
             completedDrivers += stageExecutionStats.getCompletedDrivers();
 
-            totalNewDrivers += stageExecutionStats.getTotalNewDrivers();
-            queuedNewDrivers += stageExecutionStats.getQueuedNewDrivers();
-            runningNewDrivers += stageExecutionStats.getRunningNewDrivers();
-            completedNewDrivers += stageExecutionStats.getCompletedNewDrivers();
+            totalNativeDrivers += stageExecutionStats.getTotalNativeDrivers();
+            queuedNativeDrivers += stageExecutionStats.getQueuedNativeDrivers();
+            runningNativeDrivers += stageExecutionStats.getRunningNativeDrivers();
+            completedNativeDrivers += stageExecutionStats.getCompletedNativeDrivers();
 
             totalSplits += stageExecutionStats.getTotalSplits();
             queuedSplits += stageExecutionStats.getQueuedSplits();
@@ -676,10 +676,10 @@ else if (operatorType.equals(TableScanOperator.class.getSimpleName()) || operato
                 blockedDrivers,
                 completedDrivers,
 
-                totalNewDrivers,
-                queuedNewDrivers,
-                runningNewDrivers,
-                completedNewDrivers,
+                totalNativeDrivers,
+                queuedNativeDrivers,
+                runningNativeDrivers,
+                completedNativeDrivers,
 
                 totalSplits,
                 queuedSplits,
@@ -973,27 +973,27 @@ public int getCompletedDrivers()
     }
 
     @JsonProperty
-    public int getTotalNewDrivers()
+    public int getTotalNativeDrivers()
     {
-        return totalNewDrivers;
+        return totalNativeDrivers;
     }
 
     @JsonProperty
-    public int getQueuedNewDrivers()
+    public int getQueuedNativeDrivers()
     {
-        return queuedNewDrivers;
+        return queuedNativeDrivers;
     }
 
     @JsonProperty
-    public int getRunningNewDrivers()
+    public int getRunningNativeDrivers()
     {
-        return runningNewDrivers;
+        return runningNativeDrivers;
     }
 
     @JsonProperty
-    public int getCompletedNewDrivers()
+    public int getCompletedNativeDrivers()
     {
-        return completedNewDrivers;
+        return completedNativeDrivers;
     }
 
     @JsonProperty

presto-main-base/src/main/java/com/facebook/presto/execution/StageExecutionInfo.java

@@ -113,10 +113,10 @@ public static StageExecutionInfo create(
                 taskStatsAggregator.blockedDrivers,
                 taskStatsAggregator.completedDrivers,
 
-                taskStatsAggregator.totalNewDrivers,
-                taskStatsAggregator.queuedNewDrivers,
-                taskStatsAggregator.runningNewDrivers,
-                taskStatsAggregator.completedNewDrivers,
+                taskStatsAggregator.totalNativeDrivers,
+                taskStatsAggregator.queuedNativeDrivers,
+                taskStatsAggregator.runningNativeDrivers,
+                taskStatsAggregator.completedNativeDrivers,
 
                 taskStatsAggregator.totalSplits,
                 taskStatsAggregator.queuedSplits,
@@ -256,10 +256,10 @@ private static class TaskStatsAggregator
         private int blockedDrivers;
         private int completedDrivers;
 
-        private int totalNewDrivers;
-        private int queuedNewDrivers;
-        private int runningNewDrivers;
-        private int completedNewDrivers;
+        private int totalNativeDrivers;
+        private int queuedNativeDrivers;
+        private int runningNativeDrivers;
+        private int completedNativeDrivers;
 
         private int totalSplits;
         private int queuedSplits;
@@ -311,10 +311,10 @@ public void processTaskStats(TaskStats taskStats)
             blockedDrivers += taskStats.getBlockedDrivers();
             completedDrivers += taskStats.getCompletedDrivers();
 
-            totalNewDrivers += taskStats.getTotalNewDrivers();
-            queuedNewDrivers += taskStats.getQueuedNewDrivers();
-            runningNewDrivers += taskStats.getRunningNewDrivers();
-            completedNewDrivers += taskStats.getCompletedNewDrivers();
+            totalNativeDrivers += taskStats.getTotalNativeDrivers();
+            queuedNativeDrivers += taskStats.getQueuedNativeDrivers();
+            runningNativeDrivers += taskStats.getRunningNativeDrivers();
+            completedNativeDrivers += taskStats.getCompletedNativeDrivers();
 
             totalSplits += taskStats.getTotalSplits();
             queuedSplits += taskStats.getQueuedSplits();