g11.durnev.pavel-CitiBike-WAP - Details for Query 24

Submitted Time: 2026/11/01 20:35:38
Duration: 28 s
Succeeded Jobs: 46 47 48

Show the Stage ID and Task ID that corresponds to the max metric

digraph G { 0 [labelType="html" label=" AdaptiveSparkPlan "]; 1 [labelType="html" label="Execute InsertIntoHadoopFsRelationCommand task commit time: 2.5 s number of written files: 2 job commit time: 9.5 s number of output rows: 1,190,091 number of dynamic part: 2 written output: 47.6 MiB"]; 2 [labelType="html" label=" WriteFiles "]; subgraph cluster3 { isCluster="true"; label="WholeStageCodegen (4)\n \nduration: 6.8 s"; 4 [labelType="html" label="Sort sort time: 106 ms peak memory: 416.0 MiB spill size: 0.0 B"]; 5 [labelType="html" label=" Project "]; } 6 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 104.9 MiB number of coalesced partitions: 1"]; 7 [labelType="html" label="Exchange shuffle records written: 1,190,091 local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 267 ms (0 ms, 133 ms, 134 ms (stage 69.0: task 71)) remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 1,190,091 local bytes read: 98.2 MiB fetch wait time: 0 ms remote bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 2 remote merged chunks fetched: 0 remote blocks read: 0 data size total (min, med, max (stageId: taskId)) 350.7 MiB (0.0 B, 174.8 MiB, 175.9 MiB (stage 69.0: task 71)) local merged bytes read: 0.0 B number of partitions: 200 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 98.2 MiB (0.0 B, 48.9 MiB, 49.4 MiB (stage 69.0: task 71))"]; subgraph cluster8 { isCluster="true"; label="WholeStageCodegen (3)\n \nduration: total (min, med, max (stageId: taskId))\n3.5 s (0 ms, 1.7 s, 1.8 s (stage 69.0: task 71))"; 9 [labelType="html" label=" Project "]; } 10 [labelType="html" label="Window spill size total (min, med, max (stageId: taskId)) 0.0 B (0.0 B, 0.0 B, 0.0 B (stage 69.0: task 70))"]; subgraph cluster11 { isCluster="true"; label="WholeStageCodegen (2)\n \nduration: total (min, med, max (stageId: taskId))\n6.3 s (0 ms, 3.0 s, 3.3 s (stage 69.0: task 71))"; 12 [labelType="html" label="Sort sort time total (min, med, max (stageId: taskId)) 1.8 s (0 ms, 813 ms, 995 ms (stage 69.0: task 71)) peak memory total (min, med, max (stageId: taskId)) 416.0 MiB (0.0 B, 208.0 MiB, 208.0 MiB (stage 69.0: task 70)) spill size total (min, med, max (stageId: taskId)) 0.0 B (0.0 B, 0.0 B, 0.0 B (stage 69.0: task 70))"]; } 13 [labelType="html" label="AQEShuffleRead number of partitions: 2 partition data size total (min, med, max (stageId: taskId)) 91.1 MiB (45.4 MiB, 45.6 MiB, 45.6 MiB (driver)) number of coalesced partitions: 2"]; 14 [labelType="html" label="Exchange shuffle records written: 1,190,091 local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 294 ms (0 ms, 0 ms, 153 ms (stage 67.0: task 68)) remote merged bytes read total (min, med, max (stageId: taskId)) 0.0 B (0.0 B, 0.0 B, 0.0 B (stage 69.0: task 70)) local merged blocks fetched: 0 corrupt merged block chunks: 0 remote merged reqs duration total (min, med, max (stageId: taskId)) 0 ms (0 ms, 0 ms, 0 ms (stage 69.0: task 70)) remote merged blocks fetched: 0 records read: 1,190,091 local bytes read total (min, med, max (stageId: taskId)) 86.9 MiB (0.0 B, 43.4 MiB, 43.5 MiB (stage 69.0: task 71)) fetch wait time total (min, med, max (stageId: taskId)) 0 ms (0 ms, 0 ms, 0 ms (stage 69.0: task 70)) remote bytes read total (min, med, max (stageId: taskId)) 0.0 B (0.0 B, 0.0 B, 0.0 B (stage 69.0: task 70)) merged fetch fallback count: 0 local blocks read: 4 remote merged chunks fetched: 0 remote blocks read: 0 data size total (min, med, max (stageId: taskId)) 368.9 MiB (0.0 B, 0.0 B, 191.0 MiB (stage 67.0: task 68)) local merged bytes read total (min, med, max (stageId: taskId)) 0.0 B (0.0 B, 0.0 B, 0.0 B (stage 69.0: task 70)) number of partitions: 200 remote reqs duration total (min, med, max (stageId: taskId)) 0 ms (0 ms, 0 ms, 0 ms (stage 69.0: task 70)) remote bytes read to disk total (min, med, max (stageId: taskId)) 0.0 B (0.0 B, 0.0 B, 0.0 B (stage 69.0: task 70)) shuffle bytes written total (min, med, max (stageId: taskId)) 86.9 MiB (0.0 B, 0.0 B, 44.6 MiB (stage 67.0: task 68))"]; subgraph cluster15 { isCluster="true"; label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n4.0 s (0 ms, 0 ms, 2.0 s (stage 67.0: task 68))"; 16 [labelType="html" label=" Project "]; 17 [labelType="html" label="Filter number of output rows: 1,190,091"]; } 18 [labelType="html" label="InMemoryTableScan number of output rows: 1,219,444"]; 19 [labelType="html" label=" AdaptiveSparkPlan "]; subgraph cluster20 { isCluster="true"; label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n0 ms (0 ms, 0 ms, 0 ms (stage 69.0: task 70))"; 21 [labelType="html" label=" Project "]; 22 [labelType="html" label=" Project "]; } 23 [labelType="html" label="InMemoryTableScan number of output rows: 0"]; subgraph cluster24 { isCluster="true"; label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n0 ms (0 ms, 0 ms, 0 ms (stage 69.0: task 70))"; 25 [labelType="html" label=" Project "]; } 26 [labelType="html" label="Scan csv number of output rows: 0"]; 1->0; 2->1; 4->2; 5->4; 6->5; 7->6; 9->7; 10->9; 12->10; 13->12; 14->13; 16->14; 17->16; 18->17; 19->18; 21->19; 22->21; 23->22; 25->23; 26->25; }

AdaptiveSparkPlan isFinalPlan=true

Execute InsertIntoHadoopFsRelationCommand s3a://rzvde-g11-durnev-pavel/raw_valid/citibike_data, false, [year#7599, month#7600], Parquet, [partitionOverwriteMode=dynamic, __partition_columns=["year","month"], path=s3a://rzvde-g11-durnev-pavel/raw_valid/citibike_data], Overwrite, [ride_id, rideable_type, started_at, ended_at, start_station_name, start_station_id, end_station_name, end_station_id, start_lat, start_lng, end_lat, end_lng, member_casual, _source_file, _processed_dttm, _start_station_ride_num, year, month]

WriteFiles

Sort [year#7599 ASC NULLS FIRST, month#7600 ASC NULLS FIRST], false, 0

Project [ride_id#3716, rideable_type#3717, started_at#3718, ended_at#3719, start_station_name#3720, start_station_id#3721, end_station_name#3722, end_station_id#3723, start_lat#3724, start_lng#3725, end_lat#3726, end_lng#3727, member_casual#3728, _source_file#3294, _processed_dttm#4300, _start_station_ride_num#4302, empty2null(year#4303) AS year#7599, empty2null(month#4304) AS month#7600]

WholeStageCodegen (4)

AQEShuffleRead coalesced

Exchange hashpartitioning(year#4303, month#4304, 200), REPARTITION_BY_COL, [plan_id=1677]

Project [ride_id#3716, rideable_type#3717, started_at#3718, ended_at#3719, start_station_name#3720, start_station_id#3721, end_station_name#3722, end_station_id#3723, start_lat#3724, start_lng#3725, end_lat#3726, end_lng#3727, member_casual#3728, _source_file#3294, 2026-11-01 20:35:38.488993 AS _processed_dttm#4300, _start_station_ride_num#4302, year#4303, month#4304]

WholeStageCodegen (3)

Window [row_number() windowspecdefinition(start_station_id#3721, _w0#4305, _w1#4306, started_at#3718 ASC NULLS FIRST, ride_id#3716 ASC NULLS FIRST, specifiedwindowframe(RowFrame, unboundedpreceding$(), currentrow$())) AS _start_station_ride_num#4302], [start_station_id#3721, _w0#4305, _w1#4306], [started_at#3718 ASC NULLS FIRST, ride_id#3716 ASC NULLS FIRST]

Sort [start_station_id#3721 ASC NULLS FIRST, _w0#4305 ASC NULLS FIRST, _w1#4306 ASC NULLS FIRST, started_at#3718 ASC NULLS FIRST, ride_id#3716 ASC NULLS FIRST], false, 0

WholeStageCodegen (2)

AQEShuffleRead coalesced

Exchange hashpartitioning(start_station_id#3721, _w0#4305, _w1#4306, 200), ENSURE_REQUIREMENTS, [plan_id=1610]

Project [ride_id#3716, rideable_type#3717, started_at#3718, ended_at#3719, start_station_name#3720, start_station_id#3721, end_station_name#3722, end_station_id#3723, start_lat#3724, start_lng#3725, end_lat#3726, end_lng#3727, member_casual#3728, _source_file#3294, date_format(started_at#3718, yyyy, Some(UTC)) AS year#4303, date_format(started_at#3718, MM, Some(UTC)) AS month#4304, date_format(started_at#3718, yyyy, Some(UTC)) AS _w0#4305, date_format(started_at#3718, MM, Some(UTC)) AS _w1#4306]

Filter (isnotnull(_is_valid#3747) AND _is_valid#3747)

WholeStageCodegen (1)

InMemoryTableScan [_is_valid#3747, _source_file#3294, end_lat#3726, end_lng#3727, end_station_id#3723, end_station_name#3722, ended_at#3719, member_casual#3728, ride_id#3716, rideable_type#3717, start_lat#3724, start_lng#3725, start_station_id#3721, start_station_name#3720, started_at#3718], [isnotnull(_is_valid#3747), _is_valid#3747]

AdaptiveSparkPlan isFinalPlan=true

Project [ride_id#128, rideable_type#129, started_at#669, ended_at#670, start_station_name#132, start_station_id#133, end_station_name#134, end_station_id#135, start_lat#675, start_lng#676, end_lat#677, end_lng#678, member_casual#140, _corrupt_record#141, _source_file#156, (isnotnull(ride_id#128) AND NOT (trim(ride_id#128, None) = )) AS _is_ride_id_not_empty#695, coalesce((ended_at#670 > started_at#669), false) AS _is_ended_after_started#696, coalesce(NOT (end_station_id#135 = start_station_id#133), false) AS _is_different_stations#697, ((((isnotnull(ride_id#128) AND NOT (trim(ride_id#128, None) = )) AND coalesce((ended_at#670 > started_at#669), false)) AND coalesce(NOT (end_station_id#135 = start_station_id#133), false)) AND isnull(_corrupt_record#141)) AS _is_valid#698]

Project [ride_id#128, rideable_type#129, cast(started_at#130 as timestamp) AS started_at#669, cast(ended_at#131 as timestamp) AS ended_at#670, start_station_name#132, start_station_id#133, end_station_name#134, end_station_id#135, cast(start_lat#136 as double) AS start_lat#675, cast(start_lng#137 as double) AS start_lng#676, cast(end_lat#138 as double) AS end_lat#677, cast(end_lng#139 as double) AS end_lng#678, member_casual#140, _corrupt_record#141, _source_file#156]

WholeStageCodegen (1)

InMemoryTableScan [_corrupt_record#141, _source_file#156, end_lat#138, end_lng#139, end_station_id#135, end_station_name#134, ended_at#131, member_casual#140, ride_id#128, rideable_type#129, start_lat#136, start_lng#137, start_station_id#133, start_station_name#132, started_at#130]

Project [ride_id#128, rideable_type#129, started_at#130, ended_at#131, start_station_name#132, start_station_id#133, end_station_name#134, end_station_id#135, start_lat#136, start_lng#137, end_lat#138, end_lng#139, member_casual#140, _corrupt_record#141, regexp_extract(input_file_name(), [^/]+$, 0) AS _source_file#156]

WholeStageCodegen (1)

FileScan csv [ride_id#128,rideable_type#129,started_at#130,ended_at#131,start_station_name#132,start_station_id#133,end_station_name#134,end_station_id#135,start_lat#136,start_lng#137,end_lat#138,end_lng#139,member_casual#140,_corrupt_record#141] Batched: false, DataFilters: [], Format: CSV, Location: InMemoryFileIndex(2 paths)[s3a://rzvde-g11-durnev-pavel/raw/citibike_data/202602/202602-citibike-..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<ride_id:string,rideable_type:string,started_at:string,ended_at:string,start_station_name:s...

Details

== Physical Plan ==
AdaptiveSparkPlan (37)
+- == Final Plan ==
   Execute InsertIntoHadoopFsRelationCommand (25)
   +- WriteFiles (24)
      +- * Sort (23)
         +- * Project (22)
            +- AQEShuffleRead (21)
               +- ShuffleQueryStage (20), Statistics(sizeInBytes=350.7 MiB, rowCount=1.19E+6)
                  +- Exchange (19)
                     +- * Project (18)
                        +- Window (17)
                           +- * Sort (16)
                              +- AQEShuffleRead (15)
                                 +- ShuffleQueryStage (14), Statistics(sizeInBytes=368.9 MiB, rowCount=1.19E+6)
                                    +- Exchange (13)
                                       +- * Project (12)
                                          +- * Filter (11)
                                             +- TableCacheQueryStage (10), Statistics(sizeInBytes=245.7 MiB, rowCount=1.22E+6)
                                                +- InMemoryTableScan (1)
                                                      +- InMemoryRelation (2)
                                                            +- AdaptiveSparkPlan (9)
                                                               +- Project (8)
                                                                  +- Project (7)
                                                                     +- InMemoryTableScan (3)
                                                                           +- InMemoryRelation (4)
                                                                                 +- * Project (6)
                                                                                    +- Scan csv  (5)
+- == Initial Plan ==
   Execute InsertIntoHadoopFsRelationCommand (36)
   +- WriteFiles (35)
      +- Sort (34)
         +- Project (33)
            +- Exchange (32)
               +- Project (31)
                  +- Window (30)
                     +- Sort (29)
                        +- Exchange (28)
                           +- Project (27)
                              +- Filter (26)
                                 +- InMemoryTableScan (1)
                                       +- InMemoryRelation (2)
                                             +- AdaptiveSparkPlan (9)
                                                +- Project (8)
                                                   +- Project (7)
                                                      +- InMemoryTableScan (3)
                                                            +- InMemoryRelation (4)
                                                                  +- * Project (6)
                                                                     +- Scan csv  (5)


(1) InMemoryTableScan
Output [15]: [_is_valid#3747, _source_file#3294, end_lat#3726, end_lng#3727, end_station_id#3723, end_station_name#3722, ended_at#3719, member_casual#3728, ride_id#3716, rideable_type#3717, start_lat#3724, start_lng#3725, start_station_id#3721, start_station_name#3720, started_at#3718]
Arguments: [_is_valid#3747, _source_file#3294, end_lat#3726, end_lng#3727, end_station_id#3723, end_station_name#3722, ended_at#3719, member_casual#3728, ride_id#3716, rideable_type#3717, start_lat#3724, start_lng#3725, start_station_id#3721, start_station_name#3720, started_at#3718], [isnotnull(_is_valid#3747), _is_valid#3747]

(2) InMemoryRelation
Arguments: [ride_id#3716, rideable_type#3717, started_at#3718, ended_at#3719, start_station_name#3720, start_station_id#3721, end_station_name#3722, end_station_id#3723, start_lat#3724, start_lng#3725, end_lat#3726, end_lng#3727, member_casual#3728, _corrupt_record#3279, _source_file#3294, _is_ride_id_not_empty#3744, _is_ended_after_started#3745, _is_different_stations#3746, _is_valid#3747], CachedRDDBuilder(org.apache.spark.sql.execution.columnar.DefaultCachedBatchSerializer@28f1e8bc,StorageLevel(disk, memory, deserialized, 1 replicas),AdaptiveSparkPlan isFinalPlan=true
+- == Final Plan ==
   *(1) Project [ride_id#128, rideable_type#129, started_at#669, ended_at#670, start_station_name#132, start_station_id#133, end_station_name#134, end_station_id#135, start_lat#675, start_lng#676, end_lat#677, end_lng#678, member_casual#140, _corrupt_record#141, _source_file#156, (isnotnull(ride_id#128) AND NOT (trim(ride_id#128, None) = )) AS _is_ride_id_not_empty#695, coalesce((ended_at#670 > started_at#669), false) AS _is_ended_after_started#696, coalesce(NOT (end_station_id#135 = start_station_id#133), false) AS _is_different_stations#697, ((((isnotnull(ride_id#128) AND NOT (trim(ride_id#128, None) = )) AND coalesce((ended_at#670 > started_at#669), false)) AND coalesce(NOT (end_station_id#135 = start_station_id#133), false)) AND isnull(_corrupt_record#141)) AS _is_valid#698]
   +- *(1) Project [ride_id#128, rideable_type#129, cast(started_at#130 as timestamp) AS started_at#669, cast(ended_at#131 as timestamp) AS ended_at#670, start_station_name#132, start_station_id#133, end_station_name#134, end_station_id#135, cast(start_lat#136 as double) AS start_lat#675, cast(start_lng#137 as double) AS start_lng#676, cast(end_lat#138 as double) AS end_lat#677, cast(end_lng#139 as double) AS end_lng#678, member_casual#140, _corrupt_record#141, _source_file#156]
      +- TableCacheQueryStage 0
         +- InMemoryTableScan [_corrupt_record#141, _source_file#156, end_lat#138, end_lng#139, end_station_id#135, end_station_name#134, ended_at#131, member_casual#140, ride_id#128, rideable_type#129, start_lat#136, start_lng#137, start_station_id#133, start_station_name#132, started_at#130]
               +- InMemoryRelation [ride_id#128, rideable_type#129, started_at#130, ended_at#131, start_station_name#132, start_station_id#133, end_station_name#134, end_station_id#135, start_lat#136, start_lng#137, end_lat#138, end_lng#139, member_casual#140, _corrupt_record#141, _source_file#156], StorageLevel(disk, memory, deserialized, 1 replicas)
                     +- *(1) Project [ride_id#128, rideable_type#129, started_at#130, ended_at#131, start_station_name#132, start_station_id#133, end_station_name#134, end_station_id#135, start_lat#136, start_lng#137, end_lat#138, end_lng#139, member_casual#140, _corrupt_record#141, regexp_extract(input_file_name(), [^/]+$, 0) AS _source_file#156]
                        +- FileScan csv [ride_id#128,rideable_type#129,started_at#130,ended_at#131,start_station_name#132,start_station_id#133,end_station_name#134,end_station_id#135,start_lat#136,start_lng#137,end_lat#138,end_lng#139,member_casual#140,_corrupt_record#141] Batched: false, DataFilters: [], Format: CSV, Location: InMemoryFileIndex(2 paths)[s3a://rzvde-g11-durnev-pavel/raw/citibike_data/202602/202602-citibike-..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<ride_id:string,rideable_type:string,started_at:string,ended_at:string,start_station_name:s...
+- == Initial Plan ==
   Project [ride_id#128, rideable_type#129, started_at#669, ended_at#670, start_station_name#132, start_station_id#133, end_station_name#134, end_station_id#135, start_lat#675, start_lng#676, end_lat#677, end_lng#678, member_casual#140, _corrupt_record#141, _source_file#156, (isnotnull(ride_id#128) AND NOT (trim(ride_id#128, None) = )) AS _is_ride_id_not_empty#695, coalesce((ended_at#670 > started_at#669), false) AS _is_ended_after_started#696, coalesce(NOT (end_station_id#135 = start_station_id#133), false) AS _is_different_stations#697, ((((isnotnull(ride_id#128) AND NOT (trim(ride_id#128, None) = )) AND coalesce((ended_at#670 > started_at#669), false)) AND coalesce(NOT (end_station_id#135 = start_station_id#133), false)) AND isnull(_corrupt_record#141)) AS _is_valid#698]
   +- Project [ride_id#128, rideable_type#129, cast(started_at#130 as timestamp) AS started_at#669, cast(ended_at#131 as timestamp) AS ended_at#670, start_station_name#132, start_station_id#133, end_station_name#134, end_station_id#135, cast(start_lat#136 as double) AS start_lat#675, cast(start_lng#137 as double) AS start_lng#676, cast(end_lat#138 as double) AS end_lat#677, cast(end_lng#139 as double) AS end_lng#678, member_casual#140, _corrupt_record#141, _source_file#156]
      +- InMemoryTableScan [_corrupt_record#141, _source_file#156, end_lat#138, end_lng#139, end_station_id#135, end_station_name#134, ended_at#131, member_casual#140, ride_id#128, rideable_type#129, start_lat#136, start_lng#137, start_station_id#133, start_station_name#132, started_at#130]
            +- InMemoryRelation [ride_id#128, rideable_type#129, started_at#130, ended_at#131, start_station_name#132, start_station_id#133, end_station_name#134, end_station_id#135, start_lat#136, start_lng#137, end_lat#138, end_lng#139, member_casual#140, _corrupt_record#141, _source_file#156], StorageLevel(disk, memory, deserialized, 1 replicas)
                  +- *(1) Project [ride_id#128, rideable_type#129, started_at#130, ended_at#131, start_station_name#132, start_station_id#133, end_station_name#134, end_station_id#135, start_lat#136, start_lng#137, end_lat#138, end_lng#139, member_casual#140, _corrupt_record#141, regexp_extract(input_file_name(), [^/]+$, 0) AS _source_file#156]
                     +- FileScan csv [ride_id#128,rideable_type#129,started_at#130,ended_at#131,start_station_name#132,start_station_id#133,end_station_name#134,end_station_id#135,start_lat#136,start_lng#137,end_lat#138,end_lng#139,member_casual#140,_corrupt_record#141] Batched: false, DataFilters: [], Format: CSV, Location: InMemoryFileIndex(2 paths)[s3a://rzvde-g11-durnev-pavel/raw/citibike_data/202602/202602-citibike-..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<ride_id:string,rideable_type:string,started_at:string,ended_at:string,start_station_name:s...
,None)

(3) InMemoryTableScan
Output [15]: [_corrupt_record#141, _source_file#156, end_lat#138, end_lng#139, end_station_id#135, end_station_name#134, ended_at#131, member_casual#140, ride_id#128, rideable_type#129, start_lat#136, start_lng#137, start_station_id#133, start_station_name#132, started_at#130]
Arguments: [_corrupt_record#141, _source_file#156, end_lat#138, end_lng#139, end_station_id#135, end_station_name#134, ended_at#131, member_casual#140, ride_id#128, rideable_type#129, start_lat#136, start_lng#137, start_station_id#133, start_station_name#132, started_at#130]

(4) InMemoryRelation
Arguments: [ride_id#128, rideable_type#129, started_at#130, ended_at#131, start_station_name#132, start_station_id#133, end_station_name#134, end_station_id#135, start_lat#136, start_lng#137, end_lat#138, end_lng#139, member_casual#140, _corrupt_record#141, _source_file#156], CachedRDDBuilder(org.apache.spark.sql.execution.columnar.DefaultCachedBatchSerializer@28f1e8bc,StorageLevel(disk, memory, deserialized, 1 replicas),*(1) Project [ride_id#128, rideable_type#129, started_at#130, ended_at#131, start_station_name#132, start_station_id#133, end_station_name#134, end_station_id#135, start_lat#136, start_lng#137, end_lat#138, end_lng#139, member_casual#140, _corrupt_record#141, regexp_extract(input_file_name(), [^/]+$, 0) AS _source_file#156]
+- FileScan csv [ride_id#128,rideable_type#129,started_at#130,ended_at#131,start_station_name#132,start_station_id#133,end_station_name#134,end_station_id#135,start_lat#136,start_lng#137,end_lat#138,end_lng#139,member_casual#140,_corrupt_record#141] Batched: false, DataFilters: [], Format: CSV, Location: InMemoryFileIndex(2 paths)[s3a://rzvde-g11-durnev-pavel/raw/citibike_data/202602/202602-citibike-..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<ride_id:string,rideable_type:string,started_at:string,ended_at:string,start_station_name:s...
,None)

(5) Scan csv 
Output [14]: [ride_id#128, rideable_type#129, started_at#130, ended_at#131, start_station_name#132, start_station_id#133, end_station_name#134, end_station_id#135, start_lat#136, start_lng#137, end_lat#138, end_lng#139, member_casual#140, _corrupt_record#141]
Batched: false
Location: InMemoryFileIndex [s3a://rzvde-g11-durnev-pavel/raw/citibike_data/202602/202602-citibike-tripdata-part00.csv, ... 1 entries]
ReadSchema: struct<ride_id:string,rideable_type:string,started_at:string,ended_at:string,start_station_name:string,start_station_id:string,end_station_name:string,end_station_id:string,start_lat:string,start_lng:string,end_lat:string,end_lng:string,member_casual:string,_corrupt_record:string>

(6) Project [codegen id : 1]
Output [15]: [ride_id#128, rideable_type#129, started_at#130, ended_at#131, start_station_name#132, start_station_id#133, end_station_name#134, end_station_id#135, start_lat#136, start_lng#137, end_lat#138, end_lng#139, member_casual#140, _corrupt_record#141, regexp_extract(input_file_name(), [^/]+$, 0) AS _source_file#156]
Input [14]: [ride_id#128, rideable_type#129, started_at#130, ended_at#131, start_station_name#132, start_station_id#133, end_station_name#134, end_station_id#135, start_lat#136, start_lng#137, end_lat#138, end_lng#139, member_casual#140, _corrupt_record#141]

(7) Project
Output [15]: [ride_id#128, rideable_type#129, cast(started_at#130 as timestamp) AS started_at#669, cast(ended_at#131 as timestamp) AS ended_at#670, start_station_name#132, start_station_id#133, end_station_name#134, end_station_id#135, cast(start_lat#136 as double) AS start_lat#675, cast(start_lng#137 as double) AS start_lng#676, cast(end_lat#138 as double) AS end_lat#677, cast(end_lng#139 as double) AS end_lng#678, member_casual#140, _corrupt_record#141, _source_file#156]
Input [15]: [_corrupt_record#141, _source_file#156, end_lat#138, end_lng#139, end_station_id#135, end_station_name#134, ended_at#131, member_casual#140, ride_id#128, rideable_type#129, start_lat#136, start_lng#137, start_station_id#133, start_station_name#132, started_at#130]

(8) Project
Output [19]: [ride_id#128, rideable_type#129, started_at#669, ended_at#670, start_station_name#132, start_station_id#133, end_station_name#134, end_station_id#135, start_lat#675, start_lng#676, end_lat#677, end_lng#678, member_casual#140, _corrupt_record#141, _source_file#156, (isnotnull(ride_id#128) AND NOT (trim(ride_id#128, None) = )) AS _is_ride_id_not_empty#695, coalesce((ended_at#670 > started_at#669), false) AS _is_ended_after_started#696, coalesce(NOT (end_station_id#135 = start_station_id#133), false) AS _is_different_stations#697, ((((isnotnull(ride_id#128) AND NOT (trim(ride_id#128, None) = )) AND coalesce((ended_at#670 > started_at#669), false)) AND coalesce(NOT (end_station_id#135 = start_station_id#133), false)) AND isnull(_corrupt_record#141)) AS _is_valid#698]
Input [15]: [ride_id#128, rideable_type#129, started_at#669, ended_at#670, start_station_name#132, start_station_id#133, end_station_name#134, end_station_id#135, start_lat#675, start_lng#676, end_lat#677, end_lng#678, member_casual#140, _corrupt_record#141, _source_file#156]

(9) AdaptiveSparkPlan
Output [19]: [ride_id#128, rideable_type#129, started_at#669, ended_at#670, start_station_name#132, start_station_id#133, end_station_name#134, end_station_id#135, start_lat#675, start_lng#676, end_lat#677, end_lng#678, member_casual#140, _corrupt_record#141, _source_file#156, _is_ride_id_not_empty#695, _is_ended_after_started#696, _is_different_stations#697, _is_valid#698]
Arguments: isFinalPlan=false

(10) TableCacheQueryStage
Output [15]: [_is_valid#3747, _source_file#3294, end_lat#3726, end_lng#3727, end_station_id#3723, end_station_name#3722, ended_at#3719, member_casual#3728, ride_id#3716, rideable_type#3717, start_lat#3724, start_lng#3725, start_station_id#3721, start_station_name#3720, started_at#3718]
Arguments: 0

(11) Filter [codegen id : 1]
Input [15]: [_is_valid#3747, _source_file#3294, end_lat#3726, end_lng#3727, end_station_id#3723, end_station_name#3722, ended_at#3719, member_casual#3728, ride_id#3716, rideable_type#3717, start_lat#3724, start_lng#3725, start_station_id#3721, start_station_name#3720, started_at#3718]
Condition : (isnotnull(_is_valid#3747) AND _is_valid#3747)

(12) Project [codegen id : 1]
Output [18]: [ride_id#3716, rideable_type#3717, started_at#3718, ended_at#3719, start_station_name#3720, start_station_id#3721, end_station_name#3722, end_station_id#3723, start_lat#3724, start_lng#3725, end_lat#3726, end_lng#3727, member_casual#3728, _source_file#3294, date_format(started_at#3718, yyyy, Some(UTC)) AS year#4303, date_format(started_at#3718, MM, Some(UTC)) AS month#4304, date_format(started_at#3718, yyyy, Some(UTC)) AS _w0#4305, date_format(started_at#3718, MM, Some(UTC)) AS _w1#4306]
Input [15]: [_is_valid#3747, _source_file#3294, end_lat#3726, end_lng#3727, end_station_id#3723, end_station_name#3722, ended_at#3719, member_casual#3728, ride_id#3716, rideable_type#3717, start_lat#3724, start_lng#3725, start_station_id#3721, start_station_name#3720, started_at#3718]

(13) Exchange
Input [18]: [ride_id#3716, rideable_type#3717, started_at#3718, ended_at#3719, start_station_name#3720, start_station_id#3721, end_station_name#3722, end_station_id#3723, start_lat#3724, start_lng#3725, end_lat#3726, end_lng#3727, member_casual#3728, _source_file#3294, year#4303, month#4304, _w0#4305, _w1#4306]
Arguments: hashpartitioning(start_station_id#3721, _w0#4305, _w1#4306, 200), ENSURE_REQUIREMENTS, [plan_id=1610]

(14) ShuffleQueryStage
Output [18]: [ride_id#3716, rideable_type#3717, started_at#3718, ended_at#3719, start_station_name#3720, start_station_id#3721, end_station_name#3722, end_station_id#3723, start_lat#3724, start_lng#3725, end_lat#3726, end_lng#3727, member_casual#3728, _source_file#3294, year#4303, month#4304, _w0#4305, _w1#4306]
Arguments: 1

(15) AQEShuffleRead
Input [18]: [ride_id#3716, rideable_type#3717, started_at#3718, ended_at#3719, start_station_name#3720, start_station_id#3721, end_station_name#3722, end_station_id#3723, start_lat#3724, start_lng#3725, end_lat#3726, end_lng#3727, member_casual#3728, _source_file#3294, year#4303, month#4304, _w0#4305, _w1#4306]
Arguments: coalesced

(16) Sort [codegen id : 2]
Input [18]: [ride_id#3716, rideable_type#3717, started_at#3718, ended_at#3719, start_station_name#3720, start_station_id#3721, end_station_name#3722, end_station_id#3723, start_lat#3724, start_lng#3725, end_lat#3726, end_lng#3727, member_casual#3728, _source_file#3294, year#4303, month#4304, _w0#4305, _w1#4306]
Arguments: [start_station_id#3721 ASC NULLS FIRST, _w0#4305 ASC NULLS FIRST, _w1#4306 ASC NULLS FIRST, started_at#3718 ASC NULLS FIRST, ride_id#3716 ASC NULLS FIRST], false, 0

(17) Window
Input [18]: [ride_id#3716, rideable_type#3717, started_at#3718, ended_at#3719, start_station_name#3720, start_station_id#3721, end_station_name#3722, end_station_id#3723, start_lat#3724, start_lng#3725, end_lat#3726, end_lng#3727, member_casual#3728, _source_file#3294, year#4303, month#4304, _w0#4305, _w1#4306]
Arguments: [row_number() windowspecdefinition(start_station_id#3721, _w0#4305, _w1#4306, started_at#3718 ASC NULLS FIRST, ride_id#3716 ASC NULLS FIRST, specifiedwindowframe(RowFrame, unboundedpreceding$(), currentrow$())) AS _start_station_ride_num#4302], [start_station_id#3721, _w0#4305, _w1#4306], [started_at#3718 ASC NULLS FIRST, ride_id#3716 ASC NULLS FIRST]

(18) Project [codegen id : 3]
Output [18]: [ride_id#3716, rideable_type#3717, started_at#3718, ended_at#3719, start_station_name#3720, start_station_id#3721, end_station_name#3722, end_station_id#3723, start_lat#3724, start_lng#3725, end_lat#3726, end_lng#3727, member_casual#3728, _source_file#3294, 2026-11-01 20:35:38.488993 AS _processed_dttm#4300, _start_station_ride_num#4302, year#4303, month#4304]
Input [19]: [ride_id#3716, rideable_type#3717, started_at#3718, ended_at#3719, start_station_name#3720, start_station_id#3721, end_station_name#3722, end_station_id#3723, start_lat#3724, start_lng#3725, end_lat#3726, end_lng#3727, member_casual#3728, _source_file#3294, year#4303, month#4304, _w0#4305, _w1#4306, _start_station_ride_num#4302]

(19) Exchange
Input [18]: [ride_id#3716, rideable_type#3717, started_at#3718, ended_at#3719, start_station_name#3720, start_station_id#3721, end_station_name#3722, end_station_id#3723, start_lat#3724, start_lng#3725, end_lat#3726, end_lng#3727, member_casual#3728, _source_file#3294, _processed_dttm#4300, _start_station_ride_num#4302, year#4303, month#4304]
Arguments: hashpartitioning(year#4303, month#4304, 200), REPARTITION_BY_COL, [plan_id=1677]

(20) ShuffleQueryStage
Output [18]: [ride_id#3716, rideable_type#3717, started_at#3718, ended_at#3719, start_station_name#3720, start_station_id#3721, end_station_name#3722, end_station_id#3723, start_lat#3724, start_lng#3725, end_lat#3726, end_lng#3727, member_casual#3728, _source_file#3294, _processed_dttm#4300, _start_station_ride_num#4302, year#4303, month#4304]
Arguments: 2

(21) AQEShuffleRead
Input [18]: [ride_id#3716, rideable_type#3717, started_at#3718, ended_at#3719, start_station_name#3720, start_station_id#3721, end_station_name#3722, end_station_id#3723, start_lat#3724, start_lng#3725, end_lat#3726, end_lng#3727, member_casual#3728, _source_file#3294, _processed_dttm#4300, _start_station_ride_num#4302, year#4303, month#4304]
Arguments: coalesced

(22) Project [codegen id : 4]
Output [18]: [ride_id#3716, rideable_type#3717, started_at#3718, ended_at#3719, start_station_name#3720, start_station_id#3721, end_station_name#3722, end_station_id#3723, start_lat#3724, start_lng#3725, end_lat#3726, end_lng#3727, member_casual#3728, _source_file#3294, _processed_dttm#4300, _start_station_ride_num#4302, empty2null(year#4303) AS year#7599, empty2null(month#4304) AS month#7600]
Input [18]: [ride_id#3716, rideable_type#3717, started_at#3718, ended_at#3719, start_station_name#3720, start_station_id#3721, end_station_name#3722, end_station_id#3723, start_lat#3724, start_lng#3725, end_lat#3726, end_lng#3727, member_casual#3728, _source_file#3294, _processed_dttm#4300, _start_station_ride_num#4302, year#4303, month#4304]

(23) Sort [codegen id : 4]
Input [18]: [ride_id#3716, rideable_type#3717, started_at#3718, ended_at#3719, start_station_name#3720, start_station_id#3721, end_station_name#3722, end_station_id#3723, start_lat#3724, start_lng#3725, end_lat#3726, end_lng#3727, member_casual#3728, _source_file#3294, _processed_dttm#4300, _start_station_ride_num#4302, year#7599, month#7600]
Arguments: [year#7599 ASC NULLS FIRST, month#7600 ASC NULLS FIRST], false, 0

(24) WriteFiles
Input [18]: [ride_id#3716, rideable_type#3717, started_at#3718, ended_at#3719, start_station_name#3720, start_station_id#3721, end_station_name#3722, end_station_id#3723, start_lat#3724, start_lng#3725, end_lat#3726, end_lng#3727, member_casual#3728, _source_file#3294, _processed_dttm#4300, _start_station_ride_num#4302, year#7599, month#7600]

(25) Execute InsertIntoHadoopFsRelationCommand
Input: []
Arguments: s3a://rzvde-g11-durnev-pavel/raw_valid/citibike_data, false, [year#7599, month#7600], Parquet, [partitionOverwriteMode=dynamic, __partition_columns=["year","month"], path=s3a://rzvde-g11-durnev-pavel/raw_valid/citibike_data], Overwrite, [ride_id, rideable_type, started_at, ended_at, start_station_name, start_station_id, end_station_name, end_station_id, start_lat, start_lng, end_lat, end_lng, member_casual, _source_file, _processed_dttm, _start_station_ride_num, year, month]

(26) Filter
Input [15]: [_is_valid#3747, _source_file#3294, end_lat#3726, end_lng#3727, end_station_id#3723, end_station_name#3722, ended_at#3719, member_casual#3728, ride_id#3716, rideable_type#3717, start_lat#3724, start_lng#3725, start_station_id#3721, start_station_name#3720, started_at#3718]
Condition : (isnotnull(_is_valid#3747) AND _is_valid#3747)

(27) Project
Output [18]: [ride_id#3716, rideable_type#3717, started_at#3718, ended_at#3719, start_station_name#3720, start_station_id#3721, end_station_name#3722, end_station_id#3723, start_lat#3724, start_lng#3725, end_lat#3726, end_lng#3727, member_casual#3728, _source_file#3294, date_format(started_at#3718, yyyy, Some(UTC)) AS year#4303, date_format(started_at#3718, MM, Some(UTC)) AS month#4304, date_format(started_at#3718, yyyy, Some(UTC)) AS _w0#4305, date_format(started_at#3718, MM, Some(UTC)) AS _w1#4306]
Input [15]: [_is_valid#3747, _source_file#3294, end_lat#3726, end_lng#3727, end_station_id#3723, end_station_name#3722, ended_at#3719, member_casual#3728, ride_id#3716, rideable_type#3717, start_lat#3724, start_lng#3725, start_station_id#3721, start_station_name#3720, started_at#3718]

(28) Exchange
Input [18]: [ride_id#3716, rideable_type#3717, started_at#3718, ended_at#3719, start_station_name#3720, start_station_id#3721, end_station_name#3722, end_station_id#3723, start_lat#3724, start_lng#3725, end_lat#3726, end_lng#3727, member_casual#3728, _source_file#3294, year#4303, month#4304, _w0#4305, _w1#4306]
Arguments: hashpartitioning(start_station_id#3721, _w0#4305, _w1#4306, 200), ENSURE_REQUIREMENTS, [plan_id=1524]

(29) Sort
Input [18]: [ride_id#3716, rideable_type#3717, started_at#3718, ended_at#3719, start_station_name#3720, start_station_id#3721, end_station_name#3722, end_station_id#3723, start_lat#3724, start_lng#3725, end_lat#3726, end_lng#3727, member_casual#3728, _source_file#3294, year#4303, month#4304, _w0#4305, _w1#4306]
Arguments: [start_station_id#3721 ASC NULLS FIRST, _w0#4305 ASC NULLS FIRST, _w1#4306 ASC NULLS FIRST, started_at#3718 ASC NULLS FIRST, ride_id#3716 ASC NULLS FIRST], false, 0

(30) Window
Input [18]: [ride_id#3716, rideable_type#3717, started_at#3718, ended_at#3719, start_station_name#3720, start_station_id#3721, end_station_name#3722, end_station_id#3723, start_lat#3724, start_lng#3725, end_lat#3726, end_lng#3727, member_casual#3728, _source_file#3294, year#4303, month#4304, _w0#4305, _w1#4306]
Arguments: [row_number() windowspecdefinition(start_station_id#3721, _w0#4305, _w1#4306, started_at#3718 ASC NULLS FIRST, ride_id#3716 ASC NULLS FIRST, specifiedwindowframe(RowFrame, unboundedpreceding$(), currentrow$())) AS _start_station_ride_num#4302], [start_station_id#3721, _w0#4305, _w1#4306], [started_at#3718 ASC NULLS FIRST, ride_id#3716 ASC NULLS FIRST]

(31) Project
Output [18]: [ride_id#3716, rideable_type#3717, started_at#3718, ended_at#3719, start_station_name#3720, start_station_id#3721, end_station_name#3722, end_station_id#3723, start_lat#3724, start_lng#3725, end_lat#3726, end_lng#3727, member_casual#3728, _source_file#3294, 2026-11-01 20:35:38.488993 AS _processed_dttm#4300, _start_station_ride_num#4302, year#4303, month#4304]
Input [19]: [ride_id#3716, rideable_type#3717, started_at#3718, ended_at#3719, start_station_name#3720, start_station_id#3721, end_station_name#3722, end_station_id#3723, start_lat#3724, start_lng#3725, end_lat#3726, end_lng#3727, member_casual#3728, _source_file#3294, year#4303, month#4304, _w0#4305, _w1#4306, _start_station_ride_num#4302]

(32) Exchange
Input [18]: [ride_id#3716, rideable_type#3717, started_at#3718, ended_at#3719, start_station_name#3720, start_station_id#3721, end_station_name#3722, end_station_id#3723, start_lat#3724, start_lng#3725, end_lat#3726, end_lng#3727, member_casual#3728, _source_file#3294, _processed_dttm#4300, _start_station_ride_num#4302, year#4303, month#4304]
Arguments: hashpartitioning(year#4303, month#4304, 200), REPARTITION_BY_COL, [plan_id=1528]

(33) Project
Output [18]: [ride_id#3716, rideable_type#3717, started_at#3718, ended_at#3719, start_station_name#3720, start_station_id#3721, end_station_name#3722, end_station_id#3723, start_lat#3724, start_lng#3725, end_lat#3726, end_lng#3727, member_casual#3728, _source_file#3294, _processed_dttm#4300, _start_station_ride_num#4302, empty2null(year#4303) AS year#7599, empty2null(month#4304) AS month#7600]
Input [18]: [ride_id#3716, rideable_type#3717, started_at#3718, ended_at#3719, start_station_name#3720, start_station_id#3721, end_station_name#3722, end_station_id#3723, start_lat#3724, start_lng#3725, end_lat#3726, end_lng#3727, member_casual#3728, _source_file#3294, _processed_dttm#4300, _start_station_ride_num#4302, year#4303, month#4304]

(34) Sort
Input [18]: [ride_id#3716, rideable_type#3717, started_at#3718, ended_at#3719, start_station_name#3720, start_station_id#3721, end_station_name#3722, end_station_id#3723, start_lat#3724, start_lng#3725, end_lat#3726, end_lng#3727, member_casual#3728, _source_file#3294, _processed_dttm#4300, _start_station_ride_num#4302, year#7599, month#7600]
Arguments: [year#7599 ASC NULLS FIRST, month#7600 ASC NULLS FIRST], false, 0

(35) WriteFiles
Input [18]: [ride_id#3716, rideable_type#3717, started_at#3718, ended_at#3719, start_station_name#3720, start_station_id#3721, end_station_name#3722, end_station_id#3723, start_lat#3724, start_lng#3725, end_lat#3726, end_lng#3727, member_casual#3728, _source_file#3294, _processed_dttm#4300, _start_station_ride_num#4302, year#7599, month#7600]

(36) Execute InsertIntoHadoopFsRelationCommand
Input: []
Arguments: s3a://rzvde-g11-durnev-pavel/raw_valid/citibike_data, false, [year#7599, month#7600], Parquet, [partitionOverwriteMode=dynamic, __partition_columns=["year","month"], path=s3a://rzvde-g11-durnev-pavel/raw_valid/citibike_data], Overwrite, [ride_id, rideable_type, started_at, ended_at, start_station_name, start_station_id, end_station_name, end_station_id, start_lat, start_lng, end_lat, end_lng, member_casual, _source_file, _processed_dttm, _start_station_ride_num, year, month]

(37) AdaptiveSparkPlan
Output: []
Arguments: isFinalPlan=true