== Physical Plan ==
AdaptiveSparkPlan (5)
+- == Final Plan ==
ShuffleQueryStage (3), Statistics(sizeInBytes=1760.0 B, rowCount=22)
+- Exchange (2)
+- * Scan ExistingRDD (1)
+- == Initial Plan ==
Exchange (4)
+- Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [7]: [Année-Mois Acte#292001, Acte#292002, Delta PU-NewPU#292003, Montant Total Acte-Période#292004, Nb de ligne concernée#292005L, Montant Total Facturé#292006, Total des Corrections#292007]
Arguments: [Année-Mois Acte#292001, Acte#292002, Delta PU-NewPU#292003, Montant Total Acte-Période#292004, Nb de ligne concernée#292005L, Montant Total Facturé#292006, Total des Corrections#292007], MapPartitionsRDD[4390] at createDataFrame at AbsExportExecutor.java:55, ExistingRDD, UnknownPartitioning(0)
(2) Exchange
Input [7]: [Année-Mois Acte#292001, Acte#292002, Delta PU-NewPU#292003, Montant Total Acte-Période#292004, Nb de ligne concernée#292005L, Montant Total Facturé#292006, Total des Corrections#292007]
Arguments: SinglePartition, REPARTITION_BY_NUM, [plan_id=31540]
(3) ShuffleQueryStage
Output [7]: [Année-Mois Acte#292001, Acte#292002, Delta PU-NewPU#292003, Montant Total Acte-Période#292004, Nb de ligne concernée#292005L, Montant Total Facturé#292006, Total des Corrections#292007]
Arguments: 0
(4) Exchange
Input [7]: [Année-Mois Acte#292001, Acte#292002, Delta PU-NewPU#292003, Montant Total Acte-Période#292004, Nb de ligne concernée#292005L, Montant Total Facturé#292006, Total des Corrections#292007]
Arguments: SinglePartition, REPARTITION_BY_NUM, [plan_id=31535]
(5) AdaptiveSparkPlan
Output [7]: [Année-Mois Acte#292001, Acte#292002, Delta PU-NewPU#292003, Montant Total Acte-Période#292004, Nb de ligne concernée#292005L, Montant Total Facturé#292006, Total des Corrections#292007]
Arguments: isFinalPlan=true