digraph G {
subgraph clusterstage_9 {
label="Stage 9";
subgraph cluster51 {
label="AQEShuffleRead";
23 [labelType="html" label="ShuffledRowRDD [23] [Unordered]<br>count at NativeMethodAccessorImpl.java:0"];
}
subgraph cluster48 {
label="WholeStageCodegen (2)";
24 [labelType="html" label="MapPartitionsRDD [24] [Unordered]<br>count at NativeMethodAccessorImpl.java:0"];
}
subgraph cluster47 {
label="Window";
25 [labelType="html" label="MapPartitionsRDD [25] [Unordered]<br>count at NativeMethodAccessorImpl.java:0"];
}
subgraph cluster44 {
label="WholeStageCodegen (3)";
26 [labelType="html" label="MapPartitionsRDD [26] [Unordered]<br>count at NativeMethodAccessorImpl.java:0"];
}
subgraph cluster52 {
label="mapPartitionsInternal";
27 [labelType="html" label="MapPartitionsRDD [27] [Unordered]<br>count at NativeMethodAccessorImpl.java:0"];
}
subgraph cluster53 {
label="mapPartitionsInternal";
28 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [ride_id#56, rideable_type#57, started_at#93, ended_at#94, start_station_name#60, start_station_id#124, end_station_name#62, end_station_id#155, start_lat#88, start_lng#89, end_lat#90, end_lng#91, member_casual#68, _start_station_id_fixed#109, _end_station_id_fixed#139, _ride_id_ok#171, _duration_ok#172, _station_id_ok#173, _source_file#174, 2026-11-06 11:04:13.790835 AS _processed_dttm#175, year#176, month#177, _start_station_ride_num#179]\n +- Window [row_number() windowspecdefinition(start_station_id#124, _w0#180, _w1#181, started_at#93 ASC NULLS FIRST, ride_id#56 ASC NULLS FIRST, specifiedwindowframe(RowFrame, unboundedpreceding$(), currentrow$())) AS _start_station_ride_num#179], [start_station_id#124, _w0#180, _w1#181], [started_at#93 ASC NULLS FIRST, ride_id#56 ASC NULLS FIRST]\n +- Sort [start_station_id#124 ASC NULLS FIRST, _w0#180 ASC NULLS FIRST, _w1#181 ASC NULLS FIRST, started_at#93 ASC NULLS FIRST, ride_id#56 ASC NULLS FIRST], false, 0\n ... [28] [Cached] [Unordered]<br>count at NativeMethodAccessorImpl.java:0"];
}
subgraph cluster59 {
label="InMemoryTableScan";
29 [labelType="html" label="MapPartitionsRDD [29] [Unordered]<br>count at NativeMethodAccessorImpl.java:0"];
30 [labelType="html" label="MapPartitionsRDD [30] [Unordered]<br>count at NativeMethodAccessorImpl.java:0"];
31 [labelType="html" label="MapPartitionsRDD [31] [Unordered]<br>count at NativeMethodAccessorImpl.java:0"];
}
subgraph cluster55 {
label="WholeStageCodegen (1)";
32 [labelType="html" label="MapPartitionsRDD [32] [Unordered]<br>count at NativeMethodAccessorImpl.java:0"];
}
subgraph cluster54 {
label="Exchange";
33 [labelType="html" label="MapPartitionsRDD [33] [Unordered]<br>count at NativeMethodAccessorImpl.java:0"];
}
}
23->24;
24->25;
25->26;
26->27;
27->28;
28->29;
29->30;
30->31;
31->32;
32->33;
}
22,23
28