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: 8 ms<br>number of output rows: 717<br>number of dynamic part: 0<br>written output: 63.4 KiB"];
1 [labelType="html" label="<br><b>WriteFiles</b><br><br>"];
subgraph cluster2 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 114 ms";
3 [labelType="html" label="<br><b>Project</b><br><br>"];
4 [labelType="html" label="<b>Scan JDBCRelation((SELECT RAWTOHEX(VISIT_ID), RAWTOHEX(PATIENT_ID), \"IN_DATE\", \"OUT_DATE\", \"IN_MODE\", \"OUT_MODE\", \"IN_UNIT\", \"OUT_UNIT\", \"VISIT_TYPE\", \"CHAMP_PMSI\", \"UNIT_PATH\", \"EMERGENCY\", \"CANCELED\" FROM \"DTM_622\".\"VISIT\") x) [numPartitions=1] </b><br><br>number of output rows: 717"];
}
1->0;
3->1;
4->3;
}
5
Execute InsertIntoHadoopFsRelationCommand file:/data/output/cache/parquet/uet/VISIT_3342, false, Parquet, [path=file:///data/output/cache/parquet/uet/VISIT_3342], Overwrite, [CANCELED_3355, CHAMP_PMSI_3352, EMERGENCY_3354, IN_DATE_3345, IN_MODE_3347, IN_UNIT_3349, OUT_DATE_3346, OUT_MODE_3348, OUT_UNIT_3350, PATIENT_ID_3344, UNIT_PATH_3353, VISIT_ID_3343, VISIT_TYPE_3351]
WriteFiles
Project [cast(CANCELED#61638 as int) AS CANCELED_3355#61718, CHAMP_PMSI#61635 AS CHAMP_PMSI_3352#61719, staticinvoke(class org.apache.spark.sql.catalyst.util.CharVarcharCodegenUtils, StringType, readSidePadding, EMERGENCY#61637, 1, true, false, true) AS EMERGENCY_3354#61720, IN_DATE#61628 AS IN_DATE_3345#61721, IN_MODE#61630 AS IN_MODE_3347#61722, IN_UNIT#61632 AS IN_UNIT_3349#61723, OUT_DATE#61629 AS OUT_DATE_3346#61724, OUT_MODE#61631 AS OUT_MODE_3348#61725, OUT_UNIT#61633 AS OUT_UNIT_3350#61726, RAWTOHEX(PATIENT_ID)#61627 AS PATIENT_ID_3344#61727, UNIT_PATH#61636 AS UNIT_PATH_3353#61728, RAWTOHEX(VISIT_ID)#61626 AS VISIT_ID_3343#61729, VISIT_TYPE#61634 AS VISIT_TYPE_3351#61730]
Scan JDBCRelation((SELECT RAWTOHEX(VISIT_ID), RAWTOHEX(PATIENT_ID), "IN_DATE", "OUT_DATE", "IN_MODE", "OUT_MODE", "IN_UNIT", "OUT_UNIT", "VISIT_TYPE", "CHAMP_PMSI", "UNIT_PATH", "EMERGENCY", "CANCELED" FROM "DTM_622"."VISIT") x) [numPartitions=1] [CANCELED#61638,CHAMP_PMSI#61635,EMERGENCY#61637,IN_DATE#61628,IN_MODE#61630,IN_UNIT#61632,OUT_DATE#61629,OUT_MODE#61631,OUT_UNIT#61633,RAWTOHEX(PATIENT_ID)#61627,UNIT_PATH#61636,RAWTOHEX(VISIT_ID)#61626,VISIT_TYPE#61634] PushedFilters: [], ReadSchema: struct<CANCELED:decimal(1,0),CHAMP_PMSI:string,EMERGENCY:string,IN_DATE:timestamp,IN_MODE:string,...
WholeStageCodegen (1)
== Physical Plan ==
Execute InsertIntoHadoopFsRelationCommand (4)
+- WriteFiles (3)
+- * Project (2)
+- * Scan JDBCRelation((SELECT RAWTOHEX(VISIT_ID), RAWTOHEX(PATIENT_ID), "IN_DATE", "OUT_DATE", "IN_MODE", "OUT_MODE", "IN_UNIT", "OUT_UNIT", "VISIT_TYPE", "CHAMP_PMSI", "UNIT_PATH", "EMERGENCY", "CANCELED" FROM "DTM_622"."VISIT") x) [numPartitions=1] (1)
(1) Scan JDBCRelation((SELECT RAWTOHEX(VISIT_ID), RAWTOHEX(PATIENT_ID), "IN_DATE", "OUT_DATE", "IN_MODE", "OUT_MODE", "IN_UNIT", "OUT_UNIT", "VISIT_TYPE", "CHAMP_PMSI", "UNIT_PATH", "EMERGENCY", "CANCELED" FROM "DTM_622"."VISIT") x) [numPartitions=1] [codegen id : 1]
Output [13]: [CANCELED#61638, CHAMP_PMSI#61635, EMERGENCY#61637, IN_DATE#61628, IN_MODE#61630, IN_UNIT#61632, OUT_DATE#61629, OUT_MODE#61631, OUT_UNIT#61633, RAWTOHEX(PATIENT_ID)#61627, UNIT_PATH#61636, RAWTOHEX(VISIT_ID)#61626, VISIT_TYPE#61634]
ReadSchema: struct<CANCELED:decimal(1,0),CHAMP_PMSI:string,EMERGENCY:string,IN_DATE:timestamp,IN_MODE:string,IN_UNIT:string,OUT_DATE:timestamp,OUT_MODE:string,OUT_UNIT:string,RAWTOHEX(PATIENT_ID):string,UNIT_PATH:string,RAWTOHEX(VISIT_ID):string,VISIT_TYPE:string>
(2) Project [codegen id : 1]
Output [13]: [cast(CANCELED#61638 as int) AS CANCELED_3355#61718, CHAMP_PMSI#61635 AS CHAMP_PMSI_3352#61719, staticinvoke(class org.apache.spark.sql.catalyst.util.CharVarcharCodegenUtils, StringType, readSidePadding, EMERGENCY#61637, 1, true, false, true) AS EMERGENCY_3354#61720, IN_DATE#61628 AS IN_DATE_3345#61721, IN_MODE#61630 AS IN_MODE_3347#61722, IN_UNIT#61632 AS IN_UNIT_3349#61723, OUT_DATE#61629 AS OUT_DATE_3346#61724, OUT_MODE#61631 AS OUT_MODE_3348#61725, OUT_UNIT#61633 AS OUT_UNIT_3350#61726, RAWTOHEX(PATIENT_ID)#61627 AS PATIENT_ID_3344#61727, UNIT_PATH#61636 AS UNIT_PATH_3353#61728, RAWTOHEX(VISIT_ID)#61626 AS VISIT_ID_3343#61729, VISIT_TYPE#61634 AS VISIT_TYPE_3351#61730]
Input [13]: [CANCELED#61638, CHAMP_PMSI#61635, EMERGENCY#61637, IN_DATE#61628, IN_MODE#61630, IN_UNIT#61632, OUT_DATE#61629, OUT_MODE#61631, OUT_UNIT#61633, RAWTOHEX(PATIENT_ID)#61627, UNIT_PATH#61636, RAWTOHEX(VISIT_ID)#61626, VISIT_TYPE#61634]
(3) WriteFiles
Input [13]: [CANCELED_3355#61718, CHAMP_PMSI_3352#61719, EMERGENCY_3354#61720, IN_DATE_3345#61721, IN_MODE_3347#61722, IN_UNIT_3349#61723, OUT_DATE_3346#61724, OUT_MODE_3348#61725, OUT_UNIT_3350#61726, PATIENT_ID_3344#61727, UNIT_PATH_3353#61728, VISIT_ID_3343#61729, VISIT_TYPE_3351#61730]
(4) Execute InsertIntoHadoopFsRelationCommand
Input: []
Arguments: file:/data/output/cache/parquet/uet/VISIT_3342, false, Parquet, [path=file:///data/output/cache/parquet/uet/VISIT_3342], Overwrite, [CANCELED_3355, CHAMP_PMSI_3352, EMERGENCY_3354, IN_DATE_3345, IN_MODE_3347, IN_UNIT_3349, OUT_DATE_3346, OUT_MODE_3348, OUT_UNIT_3350, PATIENT_ID_3344, UNIT_PATH_3353, VISIT_ID_3343, VISIT_TYPE_3351]