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.9 MiB"];
2->0;
3->2;
}
4
CollectLimit 6
Project [toprettystring(ride_id#201, Some(Etc/UTC)) AS toprettystring(ride_id)#285, toprettystring(rideable_type#202, Some(Etc/UTC)) AS toprettystring(rideable_type)#286, toprettystring(cast(started_at#203 as timestamp), Some(Etc/UTC)) AS toprettystring(started_at)#287, toprettystring(cast(ended_at#204 as timestamp), Some(Etc/UTC)) AS toprettystring(ended_at)#288, toprettystring(start_station_name#205, Some(Etc/UTC)) AS toprettystring(start_station_name)#289, toprettystring(start_station_id#206, Some(Etc/UTC)) AS toprettystring(start_station_id)#290, toprettystring(end_station_name#207, Some(Etc/UTC)) AS toprettystring(end_station_name)#291, toprettystring(end_station_id#208, Some(Etc/UTC)) AS toprettystring(end_station_id)#292, toprettystring(cast(start_lat#209 as double), Some(Etc/UTC)) AS toprettystring(start_lat)#293, toprettystring(cast(start_lng#210 as double), Some(Etc/UTC)) AS toprettystring(start_lng)#294, toprettystring(cast(end_lat#211 as double), Some(Etc/UTC)) AS toprettystring(end_lat)#295, toprettystring(cast(end_lng#212 as double), Some(Etc/UTC)) AS toprettystring(end_lng)#296, toprettystring(member_casual#213, Some(Etc/UTC)) AS toprettystring(member_casual)#297]
WholeStageCodegen (1)
FileScan csv [ride_id#201,rideable_type#202,started_at#203,ended_at#204,start_station_name#205,start_station_id#206,end_station_name#207,end_station_id#208,start_lat#209,start_lng#210,end_lat#211,end_lng#212,member_casual#213] 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#201, rideable_type#202, started_at#203, ended_at#204, start_station_name#205, start_station_id#206, end_station_name#207, end_station_id#208, start_lat#209, start_lng#210, end_lat#211, end_lng#212, member_casual#213]
Batched: false
Location: InMemoryFileIndex [s3a://rzvde-g11-terentyeva-kristina/raw/citibike_data/202510/202510-citibike-tripdata-part00.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#201, Some(Etc/UTC)) AS toprettystring(ride_id)#285, toprettystring(rideable_type#202, Some(Etc/UTC)) AS toprettystring(rideable_type)#286, toprettystring(cast(started_at#203 as timestamp), Some(Etc/UTC)) AS toprettystring(started_at)#287, toprettystring(cast(ended_at#204 as timestamp), Some(Etc/UTC)) AS toprettystring(ended_at)#288, toprettystring(start_station_name#205, Some(Etc/UTC)) AS toprettystring(start_station_name)#289, toprettystring(start_station_id#206, Some(Etc/UTC)) AS toprettystring(start_station_id)#290, toprettystring(end_station_name#207, Some(Etc/UTC)) AS toprettystring(end_station_name)#291, toprettystring(end_station_id#208, Some(Etc/UTC)) AS toprettystring(end_station_id)#292, toprettystring(cast(start_lat#209 as double), Some(Etc/UTC)) AS toprettystring(start_lat)#293, toprettystring(cast(start_lng#210 as double), Some(Etc/UTC)) AS toprettystring(start_lng)#294, toprettystring(cast(end_lat#211 as double), Some(Etc/UTC)) AS toprettystring(end_lat)#295, toprettystring(cast(end_lng#212 as double), Some(Etc/UTC)) AS toprettystring(end_lng)#296, toprettystring(member_casual#213, Some(Etc/UTC)) AS toprettystring(member_casual)#297]
Input [13]: [ride_id#201, rideable_type#202, started_at#203, ended_at#204, start_station_name#205, start_station_id#206, end_station_name#207, end_station_id#208, start_lat#209, start_lng#210, end_lat#211, end_lng#212, member_casual#213]
(3) CollectLimit
Input [13]: [toprettystring(ride_id)#285, toprettystring(rideable_type)#286, toprettystring(started_at)#287, toprettystring(ended_at)#288, toprettystring(start_station_name)#289, toprettystring(start_station_id)#290, toprettystring(end_station_name)#291, toprettystring(end_station_id)#292, toprettystring(start_lat)#293, toprettystring(start_lng)#294, toprettystring(end_lat)#295, toprettystring(end_lng)#296, toprettystring(member_casual)#297]
Arguments: 6