session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 190
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2024-02.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "f51353ee-b876-4820-8de9-8e595ad43048"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 188
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2023-05.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "8251ea1b-2aa4-4e33-9d45-236b851177ae"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 186
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2021-02.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "131986c8-8cfc-4db3-a6cc-6201942f62e0"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 184
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2021-04.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "d90ee069-8ce2-49c2-8ac7-5b3b13c0da5d"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 182
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2021-09.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "a2301a18-0e5c-483a-b9c5-4256bfc59c7f"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 180
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2025-08.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "bf000549-c1aa-4eb9-924e-d87ff0d8d33f"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 178
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2019-04.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "7a710e17-02ae-4a00-94f4-26950f47b03f"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 176
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2020-09.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "4aa96cc8-eac5-47dd-a15d-7d6ec84e4631"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 174
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-06.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "12b1ae76-d166-4c27-9c07-8187996ee91e"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 172
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2022-12.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "dd6f855b-4b32-4fb2-8d11-f133ff6422b0"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 170
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2020-08.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "49bf026a-31fb-4e3b-a127-7952a0a67f41"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 168
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-02.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "9d08ab95-a13f-4b32-af42-1a9b9a8db562"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 166
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2020-03.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "c9f6afc9-1002-4e61-a0c6-75a6e13466d1"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 164
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2020-02.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "68456b2c-116e-405c-9494-0c45481a30f9"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 162
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-01.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "f988164d-2a30-4c6c-812b-4ad65094c526"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 160
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2019-05.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "425e9ce3-23ef-448b-be7a-da8b0336f908"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 158
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-11.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "04c2c4d4-48cd-41f1-911a-34f31a74a4dd"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 156
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2024-07.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "2d69db4e-6414-4518-b9f7-a4f2a54548ab"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 154
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2019-07.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "2cd0c3f1-7085-448d-af0e-31d580b5d84f"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 152
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2025-11.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "b452b4b9-2c1d-401d-856d-69a829ad0aaa"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 150
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2022-10.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "b5b19e34-af5f-43f4-8dae-a7a494428649"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 148
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2024-03.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "88dfc4ad-bfe4-4e22-a465-84d5a27f6a7d"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 146
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2024-11.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "a096a92e-2cf9-4190-bd0c-07e3dea8fab7"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 144
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2024-01.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "e9d4efb1-75f2-497f-9d0f-d75b7833153b"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 142
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2024-06.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "86f21334-439e-47d0-a875-fd51c6187d5c"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 140
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2020-01.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "8d6ace22-b5ab-4313-a159-d5f59b0f7b07"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 138
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2019-10.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "52a96a13-df5e-4a95-af5a-163a6252c863"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 136
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2021-06.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "57ae2e76-b04c-45fc-bed4-787052fe1f0b"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 134
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-09.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "2b2caa6f-19ec-4b1d-a859-3e6126e4c68b"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 132
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2022-11.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "c647fcb0-13e5-47e7-a2c6-e0920af818ee"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 130
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2021-03.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "a4ec91a3-2e3c-4564-828a-1af8b644b1ba"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 128
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2023-01.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "0f6391dc-4186-438a-a313-ba7c32f0b0e6"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 126
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2023-02.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "d30ab6dc-8509-490d-9183-1f392faaeab6"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 124
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2020-10.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "0ee9b11f-8e57-463c-86a9-723e65186262"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 122
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2024-09.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "f1c57fb8-ee34-47e9-9a07-720cfd1c5e8e"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 120
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2019-11.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "581465f6-3066-4298-b9b9-5ec1adcbc575"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 118
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2021-10.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "e95632ff-dda1-4fe8-90ec-9a939137983b"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 116
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2021-11.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "dc8a1ecd-9dcf-4368-b9f1-539b5cd080ee"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 114
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-07.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "21211c3d-a004-4101-a1bb-488c89fddc2f"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 114
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-07.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "21211c3d-a004-4101-a1bb-488c89fddc2f"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 112
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2022-05.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "1b892df8-440a-4e11-8f2a-a8e9f5a0d381"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 110
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2025-06.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "5fac896b-bc68-4d5c-bcc2-abfc406e750f"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 108
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2022-06.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "821d0b0d-41ea-48a1-b8fa-a3c7cf284237"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 106
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-04.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "29dbea9c-4898-40e0-8360-9ebb3400571e"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 104
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2019-08.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "0cc0f910-7a61-4785-aaf6-54f3223e0dab"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 102
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2020-04.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "50badd40-73b6-413c-bf7f-913fa37c99a1"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 100
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2025-03.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "193c6253-94c4-4d1c-b0b0-d48c996d246e"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 98
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2025-05.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "15644fc0-5219-436f-978a-262f2851cff8"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 96
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2025-09.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "3c9481a0-0f2d-428a-9746-fcd72062da9f"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 94
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2020-07.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "00f8c9d7-c11a-411f-b7be-c0be0e2f29b0"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 92
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2021-01.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "e22ae106-151d-445f-92a5-48264e354cc9"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 90
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-03.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "14c8aa2c-e9b7-4654-8609-907121af310f"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 88
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2025-02.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "1f032c4e-d4a8-4748-b54f-a53e0013de78"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 86
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2022-09.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "d7ae4bfa-6ae1-4130-a89f-a2a3062ce403"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 84
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2023-03.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "6bc41597-674a-4fee-9ab3-55277c54abe3"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 82
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2023-10.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "b69fd70b-bb76-4198-91e3-0f7223de0693"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 80
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2022-04.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "d3e4ca73-208a-48c3-bbdf-5076a7d99caa"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 78
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2019-03.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "be22460e-a3d6-4c1d-98e9-0f8c38a34805"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 76
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2025-01.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "31428a5a-88f9-453a-b45c-c7644ee6ce7e"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 74
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2022-01.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "7338ba55-d94b-45e1-998b-8100ac497b10"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 72
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2024-05.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "4fae2a35-37ef-4ee1-a1b5-ff7757bf2cff"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 70
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2019-12.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "43d0c529-3218-4ae3-a405-0e00f1eb6600"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 68
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2021-08.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "1a81ea2a-525d-4e8d-9b12-741b7aa7c3f9"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 66
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2021-12.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "1842e87c-6411-4588-a7cc-b4a675f5ab04"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 64
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2019-09.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "d3b188fb-9986-4e7b-a6e2-4c40c4e69317"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 62
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2023-09.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "11505f12-b6ea-4784-8780-c85845c387a8"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 60
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2023-04.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "2c86dd1a-1570-4f98-9e2e-9b81a80d2006"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 58
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2024-04.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "89c328c3-476f-4d77-ae7a-980f234b092b"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 56
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2020-05.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "3a1b4a58-3756-4684-a865-1c18f8afce94"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 54
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2024-08.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "a71ebdcc-81b1-4f0f-8ba8-05eb45a4bb71"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 52
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2019-06.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "82e7c2d4-fb99-40f7-b2c3-701d13a1e7b3"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 50
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2025-04.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "453243e3-12f6-43ff-b295-28633ad30539"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 48
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-05.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "038056f6-65ae-4842-828e-83013290f29d"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 46
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2023-12.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "3a121330-0197-4c65-82ea-66cd99480a68"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 44
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2020-12.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "7a5df2e0-b57e-470b-94e5-badc2b56aa44"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 42
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2020-06.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "320e82c2-abf9-41e7-831c-5b4e4e6469f9"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 40
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2021-07.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "a9b43a10-8ee3-4cdc-b188-b967035b5a2e"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 38
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2022-07.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "19df5b34-f378-494e-81db-e3371ab2c257"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 36
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2025-12.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "858e3b2b-185a-49ad-8d3f-1c664581c01e"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 34
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2023-08.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "58782597-3c4f-4429-82f1-d7be3d74c34e"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 32
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2020-11.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "ed081ed8-4ab9-4e4d-a9d8-f25faeb6c9ed"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 30
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2025-07.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "8bcbc6a0-14e8-4a77-9380-2b94ecc9e95b"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 28
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2022-08.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "b041af04-e936-43f4-ae5f-b9c73544bfdd"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 26
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2023-06.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "43c883ae-8661-4fae-9072-fff947596643"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 24
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2022-02.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "f8ae7c29-a8ea-4205-a0a3-f1dd0000d6a4"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 22
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2024-12.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "070b7388-8ec5-4d50-b7fa-defa8b2fc8d7"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 20
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2019-02.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "993baa0e-ddcb-4699-b50a-50e6c4c21fde"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 18
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2019-01.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "ce551e70-2c11-40d6-bee9-c12c33e80063"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 16
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-12.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "035259f2-8534-4df9-9603-193cb3db6fe8"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 16
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-12.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "035259f2-8534-4df9-9603-193cb3db6fe8"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 14
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2022-03.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "d2e00546-45c8-4a1f-890f-63c0315ed1cc"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 12
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2023-07.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "ccc38014-821f-42c5-b1f5-65d5700fbadf"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 10
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2021-05.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "95614555-3777-4dfe-826f-dd28d83359e8"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 8
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-08.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "4a0e6fa4-11f8-45c5-9138-12142a2c4d93"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 8
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-08.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "4a0e6fa4-11f8-45c5-9138-12142a2c4d93"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 6
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2025-10.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "49321596-692d-4bbb-9aa6-ac0b49869aae"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 4
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2024-10.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "7eb4ab4c-6e7e-4cda-971f-5b6294638da5"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 2
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2023-11.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "f1a22686-1c05-430b-bd21-db360e87205f"
client_observed_server_side_session_id: "22ad9d42-0ffe-4297-9b48-76cbfeeba479"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 0
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-10.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "72c531e6-b91e-430c-a90f-107332e492cb"

session_id: "50cf85d5-ae27-4707-b30c-2f106b0fbf42"
plan {
  command {
    write_operation {
      input {
        common {
          plan_id: 0
        }
        read {
          data_source {
            format: "parquet"
            schema: ""
            paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-10.parquet"
          }
        }
      }
      source: "delta"
      path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
      mode: SAVE_MODE_APPEND
    }
  }
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.0 os/linux python/3.13.11"
request_options {
  result_chunking_options {
    allow_arrow_batch_chunking: true
  }
}
request_options {
  reattach_options {
    reattachable: true
  }
}
operation_id: "72c531e6-b91e-430c-a90f-107332e492cb"