digraph G {
subgraph cluster0 {
isCluster="true";
label="WholeStageCodegen (2)\n \nduration: 0 ms";
1 [labelType="html" label="<br><b>Project</b><br><br>"];
2 [labelType="html" label="<br><b>GlobalLimit</b><br><br>"];
}
3 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 10<br>shuffle write time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 27.0: task 1420))<br>records read: 5<br>local bytes read: 575.0 B<br>fetch wait time: 0 ms<br>local blocks read: 2<br>data size total (min, med, max (stageId: taskId))<br>888.0 B (440.0 B, 448.0 B, 448.0 B (stage 27.0: task 1421))<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>575.0 B (280.0 B, 295.0 B, 295.0 B (stage 27.0: task 1420))"];
subgraph cluster4 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n3 ms (1 ms, 2 ms, 2 ms (stage 27.0: task 1420))";
5 [labelType="html" label="<br><b>LocalLimit</b><br><br>"];
}
6 [labelType="html" label="<b>Scan hive itv025713_assignment_week5.gp_week5_gorcieries</b><br><br>number of output rows: 10"];
2->1;
3->2;
5->3;
6->5;
}
7
Project [order_id#325, location#326, item#327, order_date#328, cast(quantity#329 as string) AS quantity#344]
GlobalLimit 5
WholeStageCodegen (2)
Exchange SinglePartition, ENSURE_REQUIREMENTS, [id=#383]
LocalLimit 5
WholeStageCodegen (1)
Scan hive itv025713_assignment_week5.gp_week5_gorcieries [order_id#325, location#326, item#327, order_date#328, quantity#329], HiveTableRelation [`itv025713_assignment_week5`.`gp_week5_gorcieries`, org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe, Data Cols: [order_id#325, location#326, item#327, order_date#328, quantity#329], Partition Cols: []]
== Physical Plan ==
* Project (5)
+- * GlobalLimit (4)
+- Exchange (3)
+- * LocalLimit (2)
+- Scan hive itv025713_assignment_week5.gp_week5_gorcieries (1)
(1) Scan hive itv025713_assignment_week5.gp_week5_gorcieries
Output [5]: [order_id#325, location#326, item#327, order_date#328, quantity#329]
Arguments: [order_id#325, location#326, item#327, order_date#328, quantity#329], HiveTableRelation [`itv025713_assignment_week5`.`gp_week5_gorcieries`, org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe, Data Cols: [order_id#325, location#326, item#327, order_date#328, quantity#329], Partition Cols: []]
(2) LocalLimit [codegen id : 1]
Input [5]: [order_id#325, location#326, item#327, order_date#328, quantity#329]
Arguments: 5
(3) Exchange
Input [5]: [order_id#325, location#326, item#327, order_date#328, quantity#329]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [id=#383]
(4) GlobalLimit [codegen id : 2]
Input [5]: [order_id#325, location#326, item#327, order_date#328, quantity#329]
Arguments: 5
(5) Project [codegen id : 2]
Output [5]: [order_id#325, location#326, item#327, order_date#328, cast(quantity#329 as string) AS quantity#344]
Input [5]: [order_id#325, location#326, item#327, order_date#328, quantity#329]