digraph G {
0 [labelType="html" label="<br><b>CollectLimit</b><br><br>"];
subgraph cluster1 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
2 [labelType="html" label="<br><b>Project</b><br><br>"];
}
3 [labelType="html" label="<b>Scan csv </b><br><br>number of output rows: 6<br>number of files read: 1<br>metadata time: 0 ms<br>size of files read: 186.7 MiB"];
2->0;
3->2;
}
4
CollectLimit 6
Project [toprettystring(ride_id#597, Some(Etc/UTC)) AS toprettystring(ride_id)#681, toprettystring(rideable_type#598, Some(Etc/UTC)) AS toprettystring(rideable_type)#682, toprettystring(cast(started_at#599 as timestamp), Some(Etc/UTC)) AS toprettystring(started_at)#683, toprettystring(cast(ended_at#600 as timestamp), Some(Etc/UTC)) AS toprettystring(ended_at)#684, toprettystring(start_station_name#601, Some(Etc/UTC)) AS toprettystring(start_station_name)#685, toprettystring(start_station_id#602, Some(Etc/UTC)) AS toprettystring(start_station_id)#686, toprettystring(end_station_name#603, Some(Etc/UTC)) AS toprettystring(end_station_name)#687, toprettystring(end_station_id#604, Some(Etc/UTC)) AS toprettystring(end_station_id)#688, toprettystring(cast(start_lat#605 as double), Some(Etc/UTC)) AS toprettystring(start_lat)#689, toprettystring(cast(start_lng#606 as double), Some(Etc/UTC)) AS toprettystring(start_lng)#690, toprettystring(cast(end_lat#607 as double), Some(Etc/UTC)) AS toprettystring(end_lat)#691, toprettystring(cast(end_lng#608 as double), Some(Etc/UTC)) AS toprettystring(end_lng)#692, toprettystring(member_casual#609, Some(Etc/UTC)) AS toprettystring(member_casual)#693]
WholeStageCodegen (1)
FileScan csv [ride_id#597,rideable_type#598,started_at#599,ended_at#600,start_station_name#601,start_station_id#602,end_station_name#603,end_station_id#604,start_lat#605,start_lng#606,end_lat#607,end_lng#608,member_casual#609] Batched: false, DataFilters: [], Format: CSV, Location: InMemoryFileIndex(1 paths)[s3a://rzvde-g11-terentyeva-kristina/raw/citibike_data/202510/202510-ci..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<ride_id:string,rideable_type:string,started_at:string,ended_at:string,start_station_name:s...
== Physical Plan ==
CollectLimit (3)
+- * Project (2)
+- Scan csv (1)
(1) Scan csv
Output [13]: [ride_id#597, rideable_type#598, started_at#599, ended_at#600, start_station_name#601, start_station_id#602, end_station_name#603, end_station_id#604, start_lat#605, start_lng#606, end_lat#607, end_lng#608, member_casual#609]
Batched: false
Location: InMemoryFileIndex [s3a://rzvde-g11-terentyeva-kristina/raw/citibike_data/202510/202510-citibike-tripdata-part03.csv]
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>
(2) Project [codegen id : 1]
Output [13]: [toprettystring(ride_id#597, Some(Etc/UTC)) AS toprettystring(ride_id)#681, toprettystring(rideable_type#598, Some(Etc/UTC)) AS toprettystring(rideable_type)#682, toprettystring(cast(started_at#599 as timestamp), Some(Etc/UTC)) AS toprettystring(started_at)#683, toprettystring(cast(ended_at#600 as timestamp), Some(Etc/UTC)) AS toprettystring(ended_at)#684, toprettystring(start_station_name#601, Some(Etc/UTC)) AS toprettystring(start_station_name)#685, toprettystring(start_station_id#602, Some(Etc/UTC)) AS toprettystring(start_station_id)#686, toprettystring(end_station_name#603, Some(Etc/UTC)) AS toprettystring(end_station_name)#687, toprettystring(end_station_id#604, Some(Etc/UTC)) AS toprettystring(end_station_id)#688, toprettystring(cast(start_lat#605 as double), Some(Etc/UTC)) AS toprettystring(start_lat)#689, toprettystring(cast(start_lng#606 as double), Some(Etc/UTC)) AS toprettystring(start_lng)#690, toprettystring(cast(end_lat#607 as double), Some(Etc/UTC)) AS toprettystring(end_lat)#691, toprettystring(cast(end_lng#608 as double), Some(Etc/UTC)) AS toprettystring(end_lng)#692, toprettystring(member_casual#609, Some(Etc/UTC)) AS toprettystring(member_casual)#693]
Input [13]: [ride_id#597, rideable_type#598, started_at#599, ended_at#600, start_station_name#601, start_station_id#602, end_station_name#603, end_station_id#604, start_lat#605, start_lng#606, end_lat#607, end_lng#608, member_casual#609]
(3) CollectLimit
Input [13]: [toprettystring(ride_id)#681, toprettystring(rideable_type)#682, toprettystring(started_at)#683, toprettystring(ended_at)#684, toprettystring(start_station_name)#685, toprettystring(start_station_id)#686, toprettystring(end_station_name)#687, toprettystring(end_station_id)#688, toprettystring(start_lat)#689, toprettystring(start_lng)#690, toprettystring(end_lat)#691, toprettystring(end_lng)#692, toprettystring(member_casual)#693]
Arguments: 6