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: 11,307<br>number of dynamic part: 0<br>written output: 259.9 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: 234 ms";
4 [labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 11,307"];
}
1->0;
2->1;
4->2;
}
5
Execute InsertIntoHadoopFsRelationCommand file:/data/output/export/parquet/ab2f7452-6ff7-4f67-94c6-15b4d8848a85, false, Parquet, [path=file:///data/output/export/parquet/ab2f7452-6ff7-4f67-94c6-15b4d8848a85], ErrorIfExists, [Sexe, Date_Naissance, id_patient, 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, Delai-1, Delai-2]
WriteFiles
Coalesce 1
Scan ExistingRDD[Sexe#26122,Date_Naissance#26123,id_patient#26124,Date_Debut_Sejour#26125,Date_Fin_Sejour#26126,Code_Unite_Medicale#26127,Libelle_Unite_Medicale#26128,Medecin_Responsable#26129,N_Sejour#26130,Date_Prelevement#26131,Code_Analyse#26132,Libelle_Analyse#26133,Valeur#26134,Unite#26135,Valeur_Ref_Min#26136,Valeur_Ref_Max#26137,Statut#26138,Delai-1#26139L,Delai-2#26140L]
WholeStageCodegen (1)
== Physical Plan ==
Execute InsertIntoHadoopFsRelationCommand (4)
+- WriteFiles (3)
+- Coalesce (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [19]: [Sexe#26122, Date_Naissance#26123, id_patient#26124, Date_Debut_Sejour#26125, Date_Fin_Sejour#26126, Code_Unite_Medicale#26127, Libelle_Unite_Medicale#26128, Medecin_Responsable#26129, N_Sejour#26130, Date_Prelevement#26131, Code_Analyse#26132, Libelle_Analyse#26133, Valeur#26134, Unite#26135, Valeur_Ref_Min#26136, Valeur_Ref_Max#26137, Statut#26138, Delai-1#26139L, Delai-2#26140L]
Arguments: [Sexe#26122, Date_Naissance#26123, id_patient#26124, Date_Debut_Sejour#26125, Date_Fin_Sejour#26126, Code_Unite_Medicale#26127, Libelle_Unite_Medicale#26128, Medecin_Responsable#26129, N_Sejour#26130, Date_Prelevement#26131, Code_Analyse#26132, Libelle_Analyse#26133, Valeur#26134, Unite#26135, Valeur_Ref_Min#26136, Valeur_Ref_Max#26137, Statut#26138, Delai-1#26139L, Delai-2#26140L], MapPartitionsRDD[1243] at createDataFrame at AbsExportExecutor.java:55, ExistingRDD, UnknownPartitioning(0)
(2) Coalesce
Input [19]: [Sexe#26122, Date_Naissance#26123, id_patient#26124, Date_Debut_Sejour#26125, Date_Fin_Sejour#26126, Code_Unite_Medicale#26127, Libelle_Unite_Medicale#26128, Medecin_Responsable#26129, N_Sejour#26130, Date_Prelevement#26131, Code_Analyse#26132, Libelle_Analyse#26133, Valeur#26134, Unite#26135, Valeur_Ref_Min#26136, Valeur_Ref_Max#26137, Statut#26138, Delai-1#26139L, Delai-2#26140L]
Arguments: 1
(3) WriteFiles
Input [19]: [Sexe#26122, Date_Naissance#26123, id_patient#26124, Date_Debut_Sejour#26125, Date_Fin_Sejour#26126, Code_Unite_Medicale#26127, Libelle_Unite_Medicale#26128, Medecin_Responsable#26129, N_Sejour#26130, Date_Prelevement#26131, Code_Analyse#26132, Libelle_Analyse#26133, Valeur#26134, Unite#26135, Valeur_Ref_Min#26136, Valeur_Ref_Max#26137, Statut#26138, Delai-1#26139L, Delai-2#26140L]
(4) Execute InsertIntoHadoopFsRelationCommand
Input: []
Arguments: file:/data/output/export/parquet/ab2f7452-6ff7-4f67-94c6-15b4d8848a85, false, Parquet, [path=file:///data/output/export/parquet/ab2f7452-6ff7-4f67-94c6-15b4d8848a85], ErrorIfExists, [Sexe, Date_Naissance, id_patient, 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, Delai-1, Delai-2]