digraph G {
0 [labelType="html" label="<br><b>DeserializeToObject</b><br><br>"];
subgraph cluster1 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 751 ms";
2 [labelType="html" label="<br><b>Project</b><br><br>"];
3 [labelType="html" label="<b>Scan ExistingRDD</b><br><br>number of output rows: 34,851"];
}
2->0;
3->2;
}
4
DeserializeToObject createexternalrow(et_libexa#224465.toString, et_codexa#224466.toString, numdos#224467.toString, et_m_am_i#224468.toString, et_datexa#224469.toString, et_codpro#224470.toString, et_numdem#224471.toString, et_codper#224472.toString, et_codapp#224473.toString, et_ag_on#224474.toString, et_codrad#224475.toString, et_numexa#224476.toString, et_typexa#224477.toString, et_numsal#224478.toString, et_exaacc#224479.toString, staticinvoke(class java.lang.Long, ObjectType(class java.lang.Long), valueOf, id_dc_do_not_overwrite_h_detexa_438529#224495L, true, false, true), StructField(et_libexa,StringType,true), StructField(et_codexa,StringType,true), StructField(numdos,StringType,true), StructField(et_m_am_i,StringType,true), StructField(et_datexa,StringType,true), StructField(et_codpro,StringType,true), StructField(et_numdem,StringType,true), StructField(et_codper,StringType,true), ... 8 more fields), obj#224544: org.apache.spark.sql.Row
Project [et_libexa#224465, et_codexa#224466, numdos#224467, et_m_am_i#224468, et_datexa#224469, et_codpro#224470, et_numdem#224471, et_codper#224472, et_codapp#224473, et_ag_on#224474, et_codrad#224475, et_numexa#224476, et_typexa#224477, et_numsal#224478, et_exaacc#224479, monotonically_increasing_id() AS id_dc_do_not_overwrite_h_detexa_438529#224495L]
Scan ExistingRDD[et_libexa#224465,et_codexa#224466,numdos#224467,et_m_am_i#224468,et_datexa#224469,et_codpro#224470,et_numdem#224471,et_codper#224472,et_codapp#224473,et_ag_on#224474,et_codrad#224475,et_numexa#224476,et_typexa#224477,et_numsal#224478,et_exaacc#224479]
WholeStageCodegen (1)
== Physical Plan ==
DeserializeToObject (3)
+- * Project (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [15]: [et_libexa#224465, et_codexa#224466, numdos#224467, et_m_am_i#224468, et_datexa#224469, et_codpro#224470, et_numdem#224471, et_codper#224472, et_codapp#224473, et_ag_on#224474, et_codrad#224475, et_numexa#224476, et_typexa#224477, et_numsal#224478, et_exaacc#224479]
Arguments: [et_libexa#224465, et_codexa#224466, numdos#224467, et_m_am_i#224468, et_datexa#224469, et_codpro#224470, et_numdem#224471, et_codper#224472, et_codapp#224473, et_ag_on#224474, et_codrad#224475, et_numexa#224476, et_typexa#224477, et_numsal#224478, et_exaacc#224479], MapPartitionsRDD[3551] at createDataFrame at AbsExportExecutor.java:55, ExistingRDD, UnknownPartitioning(0)
(2) Project [codegen id : 1]
Output [16]: [et_libexa#224465, et_codexa#224466, numdos#224467, et_m_am_i#224468, et_datexa#224469, et_codpro#224470, et_numdem#224471, et_codper#224472, et_codapp#224473, et_ag_on#224474, et_codrad#224475, et_numexa#224476, et_typexa#224477, et_numsal#224478, et_exaacc#224479, monotonically_increasing_id() AS id_dc_do_not_overwrite_h_detexa_438529#224495L]
Input [15]: [et_libexa#224465, et_codexa#224466, numdos#224467, et_m_am_i#224468, et_datexa#224469, et_codpro#224470, et_numdem#224471, et_codper#224472, et_codapp#224473, et_ag_on#224474, et_codrad#224475, et_numexa#224476, et_typexa#224477, et_numsal#224478, et_exaacc#224479]
(3) DeserializeToObject
Input [16]: [et_libexa#224465, et_codexa#224466, numdos#224467, et_m_am_i#224468, et_datexa#224469, et_codpro#224470, et_numdem#224471, et_codper#224472, et_codapp#224473, et_ag_on#224474, et_codrad#224475, et_numexa#224476, et_typexa#224477, et_numsal#224478, et_exaacc#224479, id_dc_do_not_overwrite_h_detexa_438529#224495L]
Arguments: createexternalrow(et_libexa#224465.toString, et_codexa#224466.toString, numdos#224467.toString, et_m_am_i#224468.toString, et_datexa#224469.toString, et_codpro#224470.toString, et_numdem#224471.toString, et_codper#224472.toString, et_codapp#224473.toString, et_ag_on#224474.toString, et_codrad#224475.toString, et_numexa#224476.toString, et_typexa#224477.toString, et_numsal#224478.toString, et_exaacc#224479.toString, staticinvoke(class java.lang.Long, ObjectType(class java.lang.Long), valueOf, id_dc_do_not_overwrite_h_detexa_438529#224495L, true, false, true), StructField(et_libexa,StringType,true), StructField(et_codexa,StringType,true), StructField(numdos,StringType,true), StructField(et_m_am_i,StringType,true), StructField(et_datexa,StringType,true), StructField(et_codpro,StringType,true), StructField(et_numdem,StringType,true), StructField(et_codper,StringType,true), ... 8 more fields), obj#224544: org.apache.spark.sql.Row