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: 5<br>metadata time: 0 ms<br>size of files read: 881.3 MiB"];
2->0;
3->2;
}
4
CollectLimit 6
Project [toprettystring(ride_id#171, Some(Etc/UTC)) AS toprettystring(ride_id)#255, toprettystring(rideable_type#172, Some(Etc/UTC)) AS toprettystring(rideable_type)#256, toprettystring(cast(started_at#173 as timestamp), Some(Etc/UTC)) AS toprettystring(started_at)#257, toprettystring(cast(ended_at#174 as timestamp), Some(Etc/UTC)) AS toprettystring(ended_at)#258, toprettystring(start_station_name#175, Some(Etc/UTC)) AS toprettystring(start_station_name)#259, toprettystring(start_station_id#176, Some(Etc/UTC)) AS toprettystring(start_station_id)#260, toprettystring(end_station_name#177, Some(Etc/UTC)) AS toprettystring(end_station_name)#261, toprettystring(end_station_id#178, Some(Etc/UTC)) AS toprettystring(end_station_id)#262, toprettystring(cast(start_lat#179 as double), Some(Etc/UTC)) AS toprettystring(start_lat)#263, toprettystring(cast(start_lng#180 as double), Some(Etc/UTC)) AS toprettystring(start_lng)#264, toprettystring(cast(end_lat#181 as double), Some(Etc/UTC)) AS toprettystring(end_lat)#265, toprettystring(cast(end_lng#182 as double), Some(Etc/UTC)) AS toprettystring(end_lng)#266, toprettystring(member_casual#183, Some(Etc/UTC)) AS toprettystring(member_casual)#267]
WholeStageCodegen (1)
FileScan csv [ride_id#171,rideable_type#172,started_at#173,ended_at#174,start_station_name#175,start_station_id#176,end_station_name#177,end_station_id#178,start_lat#179,start_lng#180,end_lat#181,end_lng#182,member_casual#183] Batched: false, DataFilters: [], Format: CSV, Location: InMemoryFileIndex(5 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#171, rideable_type#172, started_at#173, ended_at#174, start_station_name#175, start_station_id#176, end_station_name#177, end_station_id#178, start_lat#179, start_lng#180, end_lat#181, end_lng#182, member_casual#183]
Batched: false
Location: InMemoryFileIndex [s3a://rzvde-g11-terentyeva-kristina/raw/citibike_data/202510/202510-citibike-tripdata-part00.csv, ... 4 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>
(2) Project [codegen id : 1]
Output [13]: [toprettystring(ride_id#171, Some(Etc/UTC)) AS toprettystring(ride_id)#255, toprettystring(rideable_type#172, Some(Etc/UTC)) AS toprettystring(rideable_type)#256, toprettystring(cast(started_at#173 as timestamp), Some(Etc/UTC)) AS toprettystring(started_at)#257, toprettystring(cast(ended_at#174 as timestamp), Some(Etc/UTC)) AS toprettystring(ended_at)#258, toprettystring(start_station_name#175, Some(Etc/UTC)) AS toprettystring(start_station_name)#259, toprettystring(start_station_id#176, Some(Etc/UTC)) AS toprettystring(start_station_id)#260, toprettystring(end_station_name#177, Some(Etc/UTC)) AS toprettystring(end_station_name)#261, toprettystring(end_station_id#178, Some(Etc/UTC)) AS toprettystring(end_station_id)#262, toprettystring(cast(start_lat#179 as double), Some(Etc/UTC)) AS toprettystring(start_lat)#263, toprettystring(cast(start_lng#180 as double), Some(Etc/UTC)) AS toprettystring(start_lng)#264, toprettystring(cast(end_lat#181 as double), Some(Etc/UTC)) AS toprettystring(end_lat)#265, toprettystring(cast(end_lng#182 as double), Some(Etc/UTC)) AS toprettystring(end_lng)#266, toprettystring(member_casual#183, Some(Etc/UTC)) AS toprettystring(member_casual)#267]
Input [13]: [ride_id#171, rideable_type#172, started_at#173, ended_at#174, start_station_name#175, start_station_id#176, end_station_name#177, end_station_id#178, start_lat#179, start_lng#180, end_lat#181, end_lng#182, member_casual#183]
(3) CollectLimit
Input [13]: [toprettystring(ride_id)#255, toprettystring(rideable_type)#256, toprettystring(started_at)#257, toprettystring(ended_at)#258, toprettystring(start_station_name)#259, toprettystring(start_station_id)#260, toprettystring(end_station_name)#261, toprettystring(end_station_id)#262, toprettystring(start_lat)#263, toprettystring(start_lng)#264, toprettystring(end_lat)#265, toprettystring(end_lng)#266, toprettystring(member_casual)#267]
Arguments: 6