digraph G {
0 [labelType="html" label="<br><b>DeserializeToObject</b><br><br>"];
subgraph cluster1 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n2.3 s (575 ms, 836 ms, 859 ms (stage 13.0: task 14))";
2 [labelType="html" label="<br><b>Project</b><br><br>"];
3 [labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 55,314"];
}
2->0;
3->2;
}
4
DeserializeToObject createexternalrow(staticinvoke(class java.lang.Double, ObjectType(class java.lang.Double), valueOf, valeur#2106, true, false, true), libelle_analyse#2107.toString, code_analyse#2108.toString, staticinvoke(class java.lang.Double, ObjectType(class java.lang.Double), valueOf, valeur_ref_min#2109, true, false, true), n_sejour#2110.toString, n_patient_etablissement#2111.toString, unite#2112.toString, staticinvoke(class java.lang.Double, ObjectType(class java.lang.Double), valueOf, valeur_ref_max#2113, true, false, true), staticinvoke(class org.apache.spark.sql.catalyst.util.DateTimeUtils$, ObjectType(class java.sql.Timestamp), toJavaTimestamp, date_prelevement#2114, true, false, true), statut#2115.toString, n_examen#2116.toString, n_mutation#2117.toString, staticinvoke(class java.lang.Long, ObjectType(class java.lang.Long), valueOf, id_dc_do_not_overwrite_biologie_exposi_24631#2130L, true, false, true), StructField(valeur,DoubleType,true), StructField(libelle_analyse,StringType,true), StructField(code_analyse,StringType,true), StructField(valeur_ref_min,DoubleType,true), StructField(n_sejour,StringType,true), StructField(n_patient_etablissement,StringType,true), StructField(unite,StringType,true), StructField(valeur_ref_max,DoubleType,true), StructField(date_prelevement,TimestampType,true), StructField(statut,StringType,true), StructField(n_examen,StringType,true), ... 2 more fields), obj#2170: org.apache.spark.sql.Row
Project [valeur#2106, libelle_analyse#2107, code_analyse#2108, valeur_ref_min#2109, n_sejour#2110, n_patient_etablissement#2111, unite#2112, valeur_ref_max#2113, date_prelevement#2114, statut#2115, n_examen#2116, n_mutation#2117, monotonically_increasing_id() AS id_dc_do_not_overwrite_biologie_exposi_24631#2130L]
Scan ExistingRDD[valeur#2106,libelle_analyse#2107,code_analyse#2108,valeur_ref_min#2109,n_sejour#2110,n_patient_etablissement#2111,unite#2112,valeur_ref_max#2113,date_prelevement#2114,statut#2115,n_examen#2116,n_mutation#2117]
WholeStageCodegen (1)
== Physical Plan ==
DeserializeToObject (3)
+- * Project (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [12]: [valeur#2106, libelle_analyse#2107, code_analyse#2108, valeur_ref_min#2109, n_sejour#2110, n_patient_etablissement#2111, unite#2112, valeur_ref_max#2113, date_prelevement#2114, statut#2115, n_examen#2116, n_mutation#2117]
Arguments: [valeur#2106, libelle_analyse#2107, code_analyse#2108, valeur_ref_min#2109, n_sejour#2110, n_patient_etablissement#2111, unite#2112, valeur_ref_max#2113, date_prelevement#2114, statut#2115, n_examen#2116, n_mutation#2117], MapPartitionsRDD[129] at createDataFrame at AbsExportExecutor.java:55, ExistingRDD, UnknownPartitioning(0)
(2) Project [codegen id : 1]
Output [13]: [valeur#2106, libelle_analyse#2107, code_analyse#2108, valeur_ref_min#2109, n_sejour#2110, n_patient_etablissement#2111, unite#2112, valeur_ref_max#2113, date_prelevement#2114, statut#2115, n_examen#2116, n_mutation#2117, monotonically_increasing_id() AS id_dc_do_not_overwrite_biologie_exposi_24631#2130L]
Input [12]: [valeur#2106, libelle_analyse#2107, code_analyse#2108, valeur_ref_min#2109, n_sejour#2110, n_patient_etablissement#2111, unite#2112, valeur_ref_max#2113, date_prelevement#2114, statut#2115, n_examen#2116, n_mutation#2117]
(3) DeserializeToObject
Input [13]: [valeur#2106, libelle_analyse#2107, code_analyse#2108, valeur_ref_min#2109, n_sejour#2110, n_patient_etablissement#2111, unite#2112, valeur_ref_max#2113, date_prelevement#2114, statut#2115, n_examen#2116, n_mutation#2117, id_dc_do_not_overwrite_biologie_exposi_24631#2130L]
Arguments: createexternalrow(staticinvoke(class java.lang.Double, ObjectType(class java.lang.Double), valueOf, valeur#2106, true, false, true), libelle_analyse#2107.toString, code_analyse#2108.toString, staticinvoke(class java.lang.Double, ObjectType(class java.lang.Double), valueOf, valeur_ref_min#2109, true, false, true), n_sejour#2110.toString, n_patient_etablissement#2111.toString, unite#2112.toString, staticinvoke(class java.lang.Double, ObjectType(class java.lang.Double), valueOf, valeur_ref_max#2113, true, false, true), staticinvoke(class org.apache.spark.sql.catalyst.util.DateTimeUtils$, ObjectType(class java.sql.Timestamp), toJavaTimestamp, date_prelevement#2114, true, false, true), statut#2115.toString, n_examen#2116.toString, n_mutation#2117.toString, staticinvoke(class java.lang.Long, ObjectType(class java.lang.Long), valueOf, id_dc_do_not_overwrite_biologie_exposi_24631#2130L, true, false, true), StructField(valeur,DoubleType,true), StructField(libelle_analyse,StringType,true), StructField(code_analyse,StringType,true), StructField(valeur_ref_min,DoubleType,true), StructField(n_sejour,StringType,true), StructField(n_patient_etablissement,StringType,true), StructField(unite,StringType,true), StructField(valeur_ref_max,DoubleType,true), StructField(date_prelevement,TimestampType,true), StructField(statut,StringType,true), StructField(n_examen,StringType,true), ... 2 more fields), obj#2170: org.apache.spark.sql.Row