digraph G {
subgraph clusterstage_14 {
label="Stage 14";
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 cluster90 {
label="InMemoryTableScan";
37 [labelType="html" label="MapPartitionsRDD [37] [Unordered]<br>first at /tmp/ipykernel_480/4147188698.py:131"];
38 [labelType="html" label="MapPartitionsRDD [38] [Unordered]<br>first at /tmp/ipykernel_480/4147188698.py:131"];
39 [labelType="html" label="MapPartitionsRDD [39] [Unordered]<br>first at /tmp/ipykernel_480/4147188698.py:131"];
}
subgraph cluster86 {
label="WholeStageCodegen (1)";
40 [labelType="html" label="MapPartitionsRDD [40] [Unordered]<br>first at /tmp/ipykernel_480/4147188698.py:131"];
}
subgraph cluster85 {
label="Exchange";
41 [labelType="html" label="MapPartitionsRDD [41] [Unordered]<br>first at /tmp/ipykernel_480/4147188698.py:131"];
}
}
23->24;
24->25;
25->26;
26->27;
27->28;
28->37;
37->38;
38->39;
39->40;
40->41;
}
22,23
28