Rename processing -> process in LuceneOperator status (#123359)

Author: idegtiarenko

x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/lucene/LuceneOperator.java

@@ -254,7 +254,7 @@ public static class Status implements Operator.Status {
         private final int processedSlices;
         private final Set<String> processedQueries;
         private final Set<String> processedShards;
-        private final long processingNanos;
+        private final long processNanos;
         private final int totalSlices;
         private final int pagesEmitted;
         private final int sliceIndex;
@@ -266,7 +266,7 @@ public static class Status implements Operator.Status {
         private Status(LuceneOperator operator) {
             processedSlices = operator.processedSlices;
             processedQueries = operator.processedQueries.stream().map(Query::toString).collect(Collectors.toCollection(TreeSet::new));
-            processingNanos = operator.processingNanos;
+            processNanos = operator.processingNanos;
             processedShards = new TreeSet<>(operator.processedShards);
             sliceIndex = operator.sliceIndex;
             totalSlices = operator.sliceQueue.totalSlices();
@@ -293,7 +293,7 @@ private Status(LuceneOperator operator) {
             int processedSlices,
             Set<String> processedQueries,
             Set<String> processedShards,
-            long processingNanos,
+            long processNanos,
             int sliceIndex,
             int totalSlices,
             int pagesEmitted,
@@ -305,7 +305,7 @@ private Status(LuceneOperator operator) {
             this.processedSlices = processedSlices;
             this.processedQueries = processedQueries;
             this.processedShards = processedShards;
-            this.processingNanos = processingNanos;
+            this.processNanos = processNanos;
             this.sliceIndex = sliceIndex;
             this.totalSlices = totalSlices;
             this.pagesEmitted = pagesEmitted;
@@ -324,7 +324,7 @@ private Status(LuceneOperator operator) {
                 processedQueries = Collections.emptySet();
                 processedShards = Collections.emptySet();
             }
-            processingNanos = in.getTransportVersion().onOrAfter(TransportVersions.V_8_14_0) ? in.readVLong() : 0;
+            processNanos = in.getTransportVersion().onOrAfter(TransportVersions.V_8_14_0) ? in.readVLong() : 0;
             sliceIndex = in.readVInt();
             totalSlices = in.readVInt();
             pagesEmitted = in.readVInt();
@@ -346,7 +346,7 @@ public void writeTo(StreamOutput out) throws IOException {
                 out.writeCollection(processedShards, StreamOutput::writeString);
             }
             if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_14_0)) {
-                out.writeVLong(processingNanos);
+                out.writeVLong(processNanos);
             }
             out.writeVInt(sliceIndex);
             out.writeVInt(totalSlices);
@@ -377,7 +377,7 @@ public Set<String> processedShards() {
         }
 
         public long processNanos() {
-            return processingNanos;
+            return processNanos;
         }
 
         public int sliceIndex() {
@@ -414,9 +414,9 @@ public XContentBuilder toXContent(XContentBuilder builder, Params params) throws
             builder.field("processed_slices", processedSlices);
             builder.field("processed_queries", processedQueries);
             builder.field("processed_shards", processedShards);
-            builder.field("processing_nanos", processingNanos);
+            builder.field("process_nanos", processNanos);
             if (builder.humanReadable()) {
-                builder.field("processing_time", TimeValue.timeValueNanos(processingNanos));
+                builder.field("process_time", TimeValue.timeValueNanos(processNanos));
             }
             builder.field("slice_index", sliceIndex);
             builder.field("total_slices", totalSlices);
@@ -436,7 +436,7 @@ public boolean equals(Object o) {
             return processedSlices == status.processedSlices
                 && processedQueries.equals(status.processedQueries)
                 && processedShards.equals(status.processedShards)
-                && processingNanos == status.processingNanos
+                && processNanos == status.processNanos
                 && sliceIndex == status.sliceIndex
                 && totalSlices == status.totalSlices
                 && pagesEmitted == status.pagesEmitted

x-pack/plugin/esql/compute/src/test/java/org/elasticsearch/compute/lucene/LuceneSourceOperatorStatusTests.java

@@ -46,8 +46,8 @@ public static String simpleToJson() {
                 "a:0",
                 "a:1"
               ],
-              "processing_nanos" : 1002,
-              "processing_time" : "1micros",
+              "process_nanos" : 1002,
+              "process_time" : "1micros",
               "slice_index" : 0,
               "total_slices" : 1,
               "pages_emitted" : 5,

x-pack/plugin/esql/qa/server/single-node/src/javaRestTest/java/org/elasticsearch/xpack/esql/qa/single_node/RestEsqlIT.java

@@ -565,7 +565,7 @@ private String checkOperatorProfile(Map<String, Object> o) {
                 .entry("current", DocIdSetIterator.NO_MORE_DOCS)
                 .entry("pages_emitted", greaterThan(0))
                 .entry("rows_emitted", greaterThan(0))
-                .entry("processing_nanos", greaterThan(0))
+                .entry("process_nanos", greaterThan(0))
                 .entry("processed_queries", List.of("*:*"));
             case "ValuesSourceReaderOperator" -> basicProfile().entry("readers_built", matchesMap().extraOk());
             case "AggregationOperator" -> matchesMap().entry("pages_processed", greaterThan(0))
@@ -599,7 +599,7 @@ private String checkOperatorProfile(Map<String, Object> o) {
                 .entry("total_slices", greaterThan(0))
                 .entry("slice_max", 0)
                 .entry("slice_min", 0)
-                .entry("processing_nanos", greaterThan(0))
+                .entry("process_nanos", greaterThan(0))
                 .entry("processed_queries", List.of("*:*"))
                 .entry("slice_index", 0);
             default -> throw new AssertionError("unexpected status: " + o);