digraph G {
0 [labelType="html" label="<b>Execute InsertIntoHadoopFsRelationCommand</b><br><br>task commit time: 1 ms<br>number of written files: 1<br>job commit time: 10 ms<br>number of output rows: 323,604<br>number of dynamic part: 0<br>written output: 101.9 MiB"];
1 [labelType="html" label="<br><b>WriteFiles</b><br><br>"];
2 [labelType="html" label="<br><b>Coalesce</b><br><br>"];
subgraph cluster3 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 3.9 s";
4 [labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 323,604"];
}
1->0;
2->1;
4->2;
}
5
Execute InsertIntoHadoopFsRelationCommand file:/data/output/export/csv/9280442d-b110-47b6-940d-87293b0ab77b, false, CSV, [path=file:///data/output/export/csv/9280442d-b110-47b6-940d-87293b0ab77b, nullValue=, ignoreLeadingWhiteSpace=true, quoteAll=false, sep=;, quote=", emptyValue=, ignoreTrailingWhiteSpace=true, escape=\, charset=UTF-8, lineSep=
, header=true], ErrorIfExists, [_c0, N°Finess, N°Séjour, Type Ligne, ROW_NUMBER, date Soin, Executant, DateNaissance_Séjour, NumSejourNorm_Séjour, N°Séjour_Séjour, DateEntree_Séjour, DateSortie__Séjour, Fides_Séjour, Fact AM_Séjour, NatureAssurance_Séjour, JustifExo_Séjour, IdLigneA_[Ref], Age-Année, ParcoursSoin_Séjour, Acte [Ref], Liste Acte RSF [Ref], Forfait Urgence, Présence_Acte_Urgence, Présence_ATU, ... 2 more fields]
WriteFiles
Coalesce 1
Scan ExistingRDD[_c0#1202501,N°Finess#1202502,N°Séjour#1202503,Type Ligne#1202504,ROW_NUMBER#1202505,date Soin#1202506,Executant#1202507,DateNaissance_Séjour#1202508,NumSejourNorm_Séjour#1202509,N°Séjour_Séjour#1202510,DateEntree_Séjour#1202511,DateSortie__Séjour#1202512,Fides_Séjour#1202513,Fact AM_Séjour#1202514,NatureAssurance_Séjour#1202515,JustifExo_Séjour#1202516,IdLigneA_[Ref]#1202517,Age-Année#1202518L,ParcoursSoin_Séjour#1202519,Acte [Ref]#1202520,Liste Acte RSF [Ref]#1202521,Forfait Urgence#1202522,Présence_Acte_Urgence#1202523,Présence_ATU#1202524,... 2 more fields]
WholeStageCodegen (1)
== Physical Plan ==
Execute InsertIntoHadoopFsRelationCommand (4)
+- WriteFiles (3)
+- Coalesce (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [26]: [_c0#1202501, N°Finess#1202502, N°Séjour#1202503, Type Ligne#1202504, ROW_NUMBER#1202505, date Soin#1202506, Executant#1202507, DateNaissance_Séjour#1202508, NumSejourNorm_Séjour#1202509, N°Séjour_Séjour#1202510, DateEntree_Séjour#1202511, DateSortie__Séjour#1202512, Fides_Séjour#1202513, Fact AM_Séjour#1202514, NatureAssurance_Séjour#1202515, JustifExo_Séjour#1202516, IdLigneA_[Ref]#1202517, Age-Année#1202518L, ParcoursSoin_Séjour#1202519, Acte [Ref]#1202520, Liste Acte RSF [Ref]#1202521, Forfait Urgence#1202522, Présence_Acte_Urgence#1202523, Présence_ATU#1202524, Acte-Exec#1202525, Liste Acte-Exec#1202526]
Arguments: [_c0#1202501, N°Finess#1202502, N°Séjour#1202503, Type Ligne#1202504, ROW_NUMBER#1202505, date Soin#1202506, Executant#1202507, DateNaissance_Séjour#1202508, NumSejourNorm_Séjour#1202509, N°Séjour_Séjour#1202510, DateEntree_Séjour#1202511, DateSortie__Séjour#1202512, Fides_Séjour#1202513, Fact AM_Séjour#1202514, NatureAssurance_Séjour#1202515, JustifExo_Séjour#1202516, IdLigneA_[Ref]#1202517, Age-Année#1202518L, ParcoursSoin_Séjour#1202519, Acte [Ref]#1202520, Liste Acte RSF [Ref]#1202521, Forfait Urgence#1202522, Présence_Acte_Urgence#1202523, Présence_ATU#1202524, ... 2 more fields], MapPartitionsRDD[42112] at createDataFrame at AbsExportExecutor.java:55, ExistingRDD, UnknownPartitioning(0)
(2) Coalesce
Input [26]: [_c0#1202501, N°Finess#1202502, N°Séjour#1202503, Type Ligne#1202504, ROW_NUMBER#1202505, date Soin#1202506, Executant#1202507, DateNaissance_Séjour#1202508, NumSejourNorm_Séjour#1202509, N°Séjour_Séjour#1202510, DateEntree_Séjour#1202511, DateSortie__Séjour#1202512, Fides_Séjour#1202513, Fact AM_Séjour#1202514, NatureAssurance_Séjour#1202515, JustifExo_Séjour#1202516, IdLigneA_[Ref]#1202517, Age-Année#1202518L, ParcoursSoin_Séjour#1202519, Acte [Ref]#1202520, Liste Acte RSF [Ref]#1202521, Forfait Urgence#1202522, Présence_Acte_Urgence#1202523, Présence_ATU#1202524, Acte-Exec#1202525, Liste Acte-Exec#1202526]
Arguments: 1
(3) WriteFiles
Input [26]: [_c0#1202501, N°Finess#1202502, N°Séjour#1202503, Type Ligne#1202504, ROW_NUMBER#1202505, date Soin#1202506, Executant#1202507, DateNaissance_Séjour#1202508, NumSejourNorm_Séjour#1202509, N°Séjour_Séjour#1202510, DateEntree_Séjour#1202511, DateSortie__Séjour#1202512, Fides_Séjour#1202513, Fact AM_Séjour#1202514, NatureAssurance_Séjour#1202515, JustifExo_Séjour#1202516, IdLigneA_[Ref]#1202517, Age-Année#1202518L, ParcoursSoin_Séjour#1202519, Acte [Ref]#1202520, Liste Acte RSF [Ref]#1202521, Forfait Urgence#1202522, Présence_Acte_Urgence#1202523, Présence_ATU#1202524, Acte-Exec#1202525, Liste Acte-Exec#1202526]
(4) Execute InsertIntoHadoopFsRelationCommand
Input: []
Arguments: file:/data/output/export/csv/9280442d-b110-47b6-940d-87293b0ab77b, false, CSV, [path=file:///data/output/export/csv/9280442d-b110-47b6-940d-87293b0ab77b, nullValue=, ignoreLeadingWhiteSpace=true, quoteAll=false, sep=;, quote=", emptyValue=, ignoreTrailingWhiteSpace=true, escape=\, charset=UTF-8, lineSep=
, header=true], ErrorIfExists, [_c0, N°Finess, N°Séjour, Type Ligne, ROW_NUMBER, date Soin, Executant, DateNaissance_Séjour, NumSejourNorm_Séjour, N°Séjour_Séjour, DateEntree_Séjour, DateSortie__Séjour, Fides_Séjour, Fact AM_Séjour, NatureAssurance_Séjour, JustifExo_Séjour, IdLigneA_[Ref], Age-Année, ParcoursSoin_Séjour, Acte [Ref], Liste Acte RSF [Ref], Forfait Urgence, Présence_Acte_Urgence, Présence_ATU, ... 2 more fields]