digraph G {
0 [labelType="html" label="<br><b>AdaptiveSparkPlan</b><br><br>"];
subgraph cluster1 {
isCluster="true";
label="WholeStageCodegen (2)\n \nduration: 0 ms";
2 [labelType="html" label="<b>HashAggregate</b><br><br>time in aggregation build: 0 ms<br>number of output rows: 1"];
}
3 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 1<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 1<br>local bytes read: 59.0 B<br>fetch wait time: 0 ms<br>remote bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 1<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 16.0 B<br>local merged bytes read: 0.0 B<br>number of partitions: 1<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 59.0 B"];
subgraph cluster4 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 178 ms";
5 [labelType="html" label="<b>HashAggregate</b><br><br>time in aggregation build: 178 ms<br>number of output rows: 1"];
6 [labelType="html" label="<b>Scan JDBCRelation((SELECT \"IPP\", \"Code \u00E9tablissement\", \"Lib \u00E9tablissement\", \"Date pr\u00E9l\u00E9vement\", \"Code examen Biologie\", \"Libell\u00E9 examen Biologie\", \"R\u00E9sultat (num\u00E9rique)\", \"Unite\", \"Code m\u00E9decin\", \"Nom m\u00E9decin\", \"Pr\u00E9nom m\u00E9decin\", \"Nom document biologie\", \"Nom complet document biologie\", \"Venue\", \"Borne basse\", \"Borne haute\" FROM \"public\".\"biologie_etb_lin\") as x) [numPartitions=1] </b><br><br>number of output rows: 471,858"];
}
2->0;
3->2;
5->3;
6->5;
}
7
AdaptiveSparkPlan isFinalPlan=true
HashAggregate(keys=[], functions=[count(1)])
WholeStageCodegen (2)
Exchange SinglePartition, ENSURE_REQUIREMENTS, [plan_id=94969]
HashAggregate(keys=[], functions=[partial_count(1)])
Scan JDBCRelation((SELECT "IPP", "Code établissement", "Lib établissement", "Date prélévement", "Code examen Biologie", "Libellé examen Biologie", "Résultat (numérique)", "Unite", "Code médecin", "Nom médecin", "Prénom médecin", "Nom document biologie", "Nom complet document biologie", "Venue", "Borne basse", "Borne haute" FROM "public"."biologie_etb_lin") as x) [numPartitions=1] [] PushedFilters: [], ReadSchema: struct<>
WholeStageCodegen (1)
== Physical Plan ==
AdaptiveSparkPlan (8)
+- == Final Plan ==
* HashAggregate (5)
+- ShuffleQueryStage (4), Statistics(sizeInBytes=16.0 B, rowCount=1)
+- Exchange (3)
+- * HashAggregate (2)
+- * Scan JDBCRelation((SELECT "IPP", "Code établissement", "Lib établissement", "Date prélévement", "Code examen Biologie", "Libellé examen Biologie", "Résultat (numérique)", "Unite", "Code médecin", "Nom médecin", "Prénom médecin", "Nom document biologie", "Nom complet document biologie", "Venue", "Borne basse", "Borne haute" FROM "public"."biologie_etb_lin") as x) [numPartitions=1] (1)
+- == Initial Plan ==
HashAggregate (7)
+- Exchange (6)
+- HashAggregate (2)
+- Scan JDBCRelation((SELECT "IPP", "Code établissement", "Lib établissement", "Date prélévement", "Code examen Biologie", "Libellé examen Biologie", "Résultat (numérique)", "Unite", "Code médecin", "Nom médecin", "Prénom médecin", "Nom document biologie", "Nom complet document biologie", "Venue", "Borne basse", "Borne haute" FROM "public"."biologie_etb_lin") as x) [numPartitions=1] (1)
(1) Scan JDBCRelation((SELECT "IPP", "Code établissement", "Lib établissement", "Date prélévement", "Code examen Biologie", "Libellé examen Biologie", "Résultat (numérique)", "Unite", "Code médecin", "Nom médecin", "Prénom médecin", "Nom document biologie", "Nom complet document biologie", "Venue", "Borne basse", "Borne haute" FROM "public"."biologie_etb_lin") as x) [numPartitions=1] [codegen id : 1]
Output: []
ReadSchema: struct<>
(2) HashAggregate [codegen id : 1]
Input: []
Keys: []
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#271326L]
Results [1]: [count#271327L]
(3) Exchange
Input [1]: [count#271327L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=94969]
(4) ShuffleQueryStage
Output [1]: [count#271327L]
Arguments: 0
(5) HashAggregate [codegen id : 2]
Input [1]: [count#271327L]
Keys: []
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#271323L]
Results [1]: [count(1)#271323L AS count#271324L]
(6) Exchange
Input [1]: [count#271327L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=94962]
(7) HashAggregate
Input [1]: [count#271327L]
Keys: []
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#271323L]
Results [1]: [count(1)#271323L AS count#271324L]
(8) AdaptiveSparkPlan
Output [1]: [count#271324L]
Arguments: isFinalPlan=true