digraph G {
0 [labelType="html" label="<b>Execute InsertIntoHadoopFsRelationCommand</b><br><br>task commit time: 12 ms<br>number of written files: 1<br>job commit time: 19 ms<br>number of output rows: 18,140<br>number of dynamic part: 0<br>written output: 308.4 KiB"];
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: 537 ms";
4 [labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 18,140"];
}
1->0;
2->1;
4->2;
}
5
Execute InsertIntoHadoopFsRelationCommand file:/data/output/export/parquet/d5878280-67dc-4255-9798-3cd17b544b45, false, Parquet, [path=file:///data/output/export/parquet/d5878280-67dc-4255-9798-3cd17b544b45], ErrorIfExists, [Sexe, Date_Naissance, ID_PATIENT_Bis, Date_Debut_Sejour, Date_Fin_Sejour, Code_Unite_Medicale, Libelle_Unite_Medicale, Medecin_Responsable, N_Sejour, Date_Prelevement, Code_Analyse, Libelle_Analyse, Valeur, Unite, Valeur_Ref_Min, Valeur_Ref_Max, Statut]
WriteFiles
Coalesce 1
Scan ExistingRDD[Sexe#919,Date_Naissance#920,ID_PATIENT_Bis#921,Date_Debut_Sejour#922,Date_Fin_Sejour#923,Code_Unite_Medicale#924,Libelle_Unite_Medicale#925,Medecin_Responsable#926,N_Sejour#927,Date_Prelevement#928,Code_Analyse#929,Libelle_Analyse#930,Valeur#931,Unite#932,Valeur_Ref_Min#933,Valeur_Ref_Max#934,Statut#935]
WholeStageCodegen (1)
== Physical Plan ==
Execute InsertIntoHadoopFsRelationCommand (4)
+- WriteFiles (3)
+- Coalesce (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [17]: [Sexe#919, Date_Naissance#920, ID_PATIENT_Bis#921, Date_Debut_Sejour#922, Date_Fin_Sejour#923, Code_Unite_Medicale#924, Libelle_Unite_Medicale#925, Medecin_Responsable#926, N_Sejour#927, Date_Prelevement#928, Code_Analyse#929, Libelle_Analyse#930, Valeur#931, Unite#932, Valeur_Ref_Min#933, Valeur_Ref_Max#934, Statut#935]
Arguments: [Sexe#919, Date_Naissance#920, ID_PATIENT_Bis#921, Date_Debut_Sejour#922, Date_Fin_Sejour#923, Code_Unite_Medicale#924, Libelle_Unite_Medicale#925, Medecin_Responsable#926, N_Sejour#927, Date_Prelevement#928, Code_Analyse#929, Libelle_Analyse#930, Valeur#931, Unite#932, Valeur_Ref_Min#933, Valeur_Ref_Max#934, Statut#935], MapPartitionsRDD[67] at createDataFrame at AbsExportExecutor.java:55, ExistingRDD, UnknownPartitioning(0)
(2) Coalesce
Input [17]: [Sexe#919, Date_Naissance#920, ID_PATIENT_Bis#921, Date_Debut_Sejour#922, Date_Fin_Sejour#923, Code_Unite_Medicale#924, Libelle_Unite_Medicale#925, Medecin_Responsable#926, N_Sejour#927, Date_Prelevement#928, Code_Analyse#929, Libelle_Analyse#930, Valeur#931, Unite#932, Valeur_Ref_Min#933, Valeur_Ref_Max#934, Statut#935]
Arguments: 1
(3) WriteFiles
Input [17]: [Sexe#919, Date_Naissance#920, ID_PATIENT_Bis#921, Date_Debut_Sejour#922, Date_Fin_Sejour#923, Code_Unite_Medicale#924, Libelle_Unite_Medicale#925, Medecin_Responsable#926, N_Sejour#927, Date_Prelevement#928, Code_Analyse#929, Libelle_Analyse#930, Valeur#931, Unite#932, Valeur_Ref_Min#933, Valeur_Ref_Max#934, Statut#935]
(4) Execute InsertIntoHadoopFsRelationCommand
Input: []
Arguments: file:/data/output/export/parquet/d5878280-67dc-4255-9798-3cd17b544b45, false, Parquet, [path=file:///data/output/export/parquet/d5878280-67dc-4255-9798-3cd17b544b45], ErrorIfExists, [Sexe, Date_Naissance, ID_PATIENT_Bis, Date_Debut_Sejour, Date_Fin_Sejour, Code_Unite_Medicale, Libelle_Unite_Medicale, Medecin_Responsable, N_Sejour, Date_Prelevement, Code_Analyse, Libelle_Analyse, Valeur, Unite, Valeur_Ref_Min, Valeur_Ref_Max, Statut]