digraph G {
0 [labelType="html" label="<br><b>DeserializeToObject</b><br><br>"];
subgraph cluster1 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 884 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#221746.toString, et_codexa#221747.toString, et_numdos#221748.toString, et_m_am_i#221749.toString, et_datexa#221750.toString, et_codpro#221751.toString, et_numdem#221752.toString, et_codper#221753.toString, et_codapp#221754.toString, et_ag_on#221755.toString, et_codrad#221756.toString, et_numexa#221757.toString, et_typexa#221758.toString, et_numsal#221759.toString, et_exaacc#221760.toString, staticinvoke(class java.lang.Long, ObjectType(class java.lang.Long), valueOf, id_dc_do_not_overwrite_h_detexa_438529#221776L, true, false, true), StructField(et_libexa,StringType,true), StructField(et_codexa,StringType,true), StructField(et_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#221825: org.apache.spark.sql.Row
Project [et_libexa#221746, et_codexa#221747, et_numdos#221748, et_m_am_i#221749, et_datexa#221750, et_codpro#221751, et_numdem#221752, et_codper#221753, et_codapp#221754, et_ag_on#221755, et_codrad#221756, et_numexa#221757, et_typexa#221758, et_numsal#221759, et_exaacc#221760, monotonically_increasing_id() AS id_dc_do_not_overwrite_h_detexa_438529#221776L]
Scan ExistingRDD[et_libexa#221746,et_codexa#221747,et_numdos#221748,et_m_am_i#221749,et_datexa#221750,et_codpro#221751,et_numdem#221752,et_codper#221753,et_codapp#221754,et_ag_on#221755,et_codrad#221756,et_numexa#221757,et_typexa#221758,et_numsal#221759,et_exaacc#221760]
WholeStageCodegen (1)
== Physical Plan ==
DeserializeToObject (3)
+- * Project (2)
+- * Scan ExistingRDD (1)
(1) Scan ExistingRDD [codegen id : 1]
Output [15]: [et_libexa#221746, et_codexa#221747, et_numdos#221748, et_m_am_i#221749, et_datexa#221750, et_codpro#221751, et_numdem#221752, et_codper#221753, et_codapp#221754, et_ag_on#221755, et_codrad#221756, et_numexa#221757, et_typexa#221758, et_numsal#221759, et_exaacc#221760]
Arguments: [et_libexa#221746, et_codexa#221747, et_numdos#221748, et_m_am_i#221749, et_datexa#221750, et_codpro#221751, et_numdem#221752, et_codper#221753, et_codapp#221754, et_ag_on#221755, et_codrad#221756, et_numexa#221757, et_typexa#221758, et_numsal#221759, et_exaacc#221760], MapPartitionsRDD[3525] at createDataFrame at AbsExportExecutor.java:55, ExistingRDD, UnknownPartitioning(0)
(2) Project [codegen id : 1]
Output [16]: [et_libexa#221746, et_codexa#221747, et_numdos#221748, et_m_am_i#221749, et_datexa#221750, et_codpro#221751, et_numdem#221752, et_codper#221753, et_codapp#221754, et_ag_on#221755, et_codrad#221756, et_numexa#221757, et_typexa#221758, et_numsal#221759, et_exaacc#221760, monotonically_increasing_id() AS id_dc_do_not_overwrite_h_detexa_438529#221776L]
Input [15]: [et_libexa#221746, et_codexa#221747, et_numdos#221748, et_m_am_i#221749, et_datexa#221750, et_codpro#221751, et_numdem#221752, et_codper#221753, et_codapp#221754, et_ag_on#221755, et_codrad#221756, et_numexa#221757, et_typexa#221758, et_numsal#221759, et_exaacc#221760]
(3) DeserializeToObject
Input [16]: [et_libexa#221746, et_codexa#221747, et_numdos#221748, et_m_am_i#221749, et_datexa#221750, et_codpro#221751, et_numdem#221752, et_codper#221753, et_codapp#221754, et_ag_on#221755, et_codrad#221756, et_numexa#221757, et_typexa#221758, et_numsal#221759, et_exaacc#221760, id_dc_do_not_overwrite_h_detexa_438529#221776L]
Arguments: createexternalrow(et_libexa#221746.toString, et_codexa#221747.toString, et_numdos#221748.toString, et_m_am_i#221749.toString, et_datexa#221750.toString, et_codpro#221751.toString, et_numdem#221752.toString, et_codper#221753.toString, et_codapp#221754.toString, et_ag_on#221755.toString, et_codrad#221756.toString, et_numexa#221757.toString, et_typexa#221758.toString, et_numsal#221759.toString, et_exaacc#221760.toString, staticinvoke(class java.lang.Long, ObjectType(class java.lang.Long), valueOf, id_dc_do_not_overwrite_h_detexa_438529#221776L, true, false, true), StructField(et_libexa,StringType,true), StructField(et_codexa,StringType,true), StructField(et_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#221825: org.apache.spark.sql.Row