Profile serialization

Author: not-napoleon

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/action/EsqlQueryResponse.java

@@ -375,6 +375,9 @@ public Profile(StreamInput in) throws IOException {
         @Override
         public void writeTo(StreamOutput out) throws IOException {
             out.writeCollection(drivers);
+            if (out.getTransportVersion().onOrAfter(TransportVersions.ESQL_PLANNER_PROFILE)) {
+                out.writeCollection(plannerProfile);
+            }
         }
 
         @Override

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/planner/PlannerProfile.java

@@ -22,24 +22,22 @@
  */
 public class PlannerProfile implements Writeable, ChunkedToXContentObject {
 
-    public static final PlannerProfile EMPTY = new PlannerProfile();
+    public static final PlannerProfile EMPTY = new PlannerProfile(false);
 
     private final boolean isLocalPlanning;
 
     public static PlannerProfile readFrom(StreamInput in) throws IOException {
-        // NOCOMMIT
-        throw new UnsupportedOperationException();
+        boolean isLocalPlanning = in.readBoolean();
+        return new PlannerProfile(isLocalPlanning);
     }
 
-    public PlannerProfile() {
-        // NOCOMMIT
-        throw new UnsupportedOperationException();
+    public PlannerProfile(boolean isLocalPlanning) {
+        this.isLocalPlanning = isLocalPlanning;
     }
 
     @Override
     public void writeTo(StreamOutput out) throws IOException {
-        // NOCOMMIT
-        throw new UnsupportedOperationException();
+        out.writeBoolean(isLocalPlanning);
     }
 
     @Override

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/plugin/ComputeService.java

@@ -369,7 +369,7 @@ public SourceProvider createSourceProvider() {
             );
         }
         final List<Driver> drivers;
-        final PlannerProfile localPlannerProfile = new PlannerProfile();
+        final PlannerProfile localPlannerProfile = new PlannerProfile(true);
         try {
             LocalExecutionPlanner planner = new LocalExecutionPlanner(
                 context.sessionId(),

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/session/EsqlSession.java

@@ -148,7 +148,7 @@ public EsqlSession(
         this.logicalPlanOptimizer = logicalPlanOptimizer;
         this.physicalPlanOptimizer = new PhysicalPlanOptimizer(new PhysicalOptimizerContext(configuration));
         this.planTelemetry = planTelemetry;
-        this.plannerProfile = new PlannerProfile();
+        this.plannerProfile = new PlannerProfile(false);
         this.indicesExpressionGrouper = indicesExpressionGrouper;
         this.preMapper = new PreMapper(services);
     }