Spark Connect - session_id: "c59ec071-5292-46c9-ba54-05968ea7765f"
plan {
  root {
    common {
      plan_id: 1
    }
    show_string {
    ...

session_id: "c59ec071-5292-46c9-ba54-05968ea7765f"
plan {
  root {
    common {
      plan_id: 1
    }
    show_string {
      input {
        common {
          plan_id: 0
        }
        read {
          data_source {
            format: "json"
            schema: ""
            options {
              key: "multiLine"
              value: "true"
            }
            paths: "/home/jovyan/data/openaq-api-data/"
          }
        }
      }
      num_rows: 20
      truncate: 20
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/3.5.3 os/linux python/3.11.10"
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "f9b69ec2-4dbc-4ed5-9734-76139a10d9e6"

Spark Connect - session_id: "026f81c9-b603-4b85-9d3e-64b71b17fbda"
plan {
  root {
    common {
      plan_id: 2
    }
    aggregate {
      ...

session_id: "026f81c9-b603-4b85-9d3e-64b71b17fbda"
plan {
  root {
    common {
      plan_id: 2
    }
    aggregate {
      input {
        common {
          plan_id: 1
        }
        aggregate {
          input {
            common {
              plan_id: 0
            }
            read {
              data_source {
                format: "parquet"
                schema: ""
                paths: "/home/jovyan/inbound/fhvhv_tripdata_2025-01.parquet"
              }
            }
          }
          group_type: GROUP_TYPE_GROUPBY
          grouping_expressions {
            unresolved_function {
              function_name: "to_date"
              arguments {
                unresolved_attribute {
                  unparsed_identifier: "pickup_datetime"
                }
              }
            }
          }
          aggregate_expressions {
            alias {
              expr {
                unresolved_function {
                  function_name: "count"
                  arguments {
                    literal {
                      integer: 1
                    }
                  }
                }
              }
              name: "count"
            }
          }
        }
      }
      group_type: GROUP_TYPE_GROUPBY
      aggregate_expressions {
        unresolved_function {
          function_name: "count"
          arguments {
            literal {
              integer: 1
            }
          }
        }
      }
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/3.5.3 os/linux python/3.11.10"
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "9c896837-8564-43f0-9e9e-bb9b32a48a62"

Spark Connect - session_id: "ddcf55a3-6421-409c-b691-26dfe4527c69"
plan {
  root {
    common {
      plan_id: 1
    }
    show_string {
    ...

session_id: "ddcf55a3-6421-409c-b691-26dfe4527c69"
plan {
  root {
    common {
      plan_id: 1
    }
    show_string {
      input {
        common {
          plan_id: 0
        }
        range {
          start: 0
          end: 1000
          step: 1
        }
      }
      num_rows: 20
      truncate: 20
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/3.5.3 os/linux python/3.11.10"
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "2804bcea-2cbc-41f9-83b5-3e53db972423"