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: 6 ms<br>number of output rows: 189<br>number of dynamic part: 0<br>written output: 11.3 KiB"];
1 [labelType="html" label="<br><b>WriteFiles</b><br><br>"];
subgraph cluster2 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 108 ms";
3 [labelType="html" label="<br><b>Project</b><br><br>"];
4 [labelType="html" label="<b>Scan JDBCRelation((SELECT RAWTOHEX(PATIENT_ID), \"BIRTH_DATE\", \"GENDER\", \"PSEUDO\", \"INHOSPITAL_DEATH_DATE\", \"INHOSPITAL_DEATH_CODE\", \"DEATH_DATE\", \"EXTERNAL_DEATH_PROCESS_ID\" FROM \"DTM_622\".\"PATIENT\") x) [numPartitions=1] </b><br><br>number of output rows: 189"];
}
1->0;
3->1;
4->3;
}
5
Execute InsertIntoHadoopFsRelationCommand file:/data/output/cache/parquet/uet/PATIENT_3332, false, Parquet, [path=file:///data/output/cache/parquet/uet/PATIENT_3332], Overwrite, [BIRTH_DATE_3334, DEATH_DATE_3339, EXTERNAL_DEATH__3340, GENDER_3335, INHOSPITAL_DEAT_3337, INHOSPITAL_DEAT_3338, PATIENT_ID_3333, PSEUDO_3336]
WriteFiles
Project [BIRTH_DATE#104815 AS BIRTH_DATE_3334#104870, DEATH_DATE#104820 AS DEATH_DATE_3339#104871, cast(EXTERNAL_DEATH_PROCESS_ID#104821 as int) AS EXTERNAL_DEATH__3340#104872, GENDER#104816 AS GENDER_3335#104873, INHOSPITAL_DEATH_DATE#104818 AS INHOSPITAL_DEAT_3337#104874, INHOSPITAL_DEATH_CODE#104819 AS INHOSPITAL_DEAT_3338#104875, RAWTOHEX(PATIENT_ID)#104814 AS PATIENT_ID_3333#104876, PSEUDO#104817 AS PSEUDO_3336#104877]
Scan JDBCRelation((SELECT RAWTOHEX(PATIENT_ID), "BIRTH_DATE", "GENDER", "PSEUDO", "INHOSPITAL_DEATH_DATE", "INHOSPITAL_DEATH_CODE", "DEATH_DATE", "EXTERNAL_DEATH_PROCESS_ID" FROM "DTM_622"."PATIENT") x) [numPartitions=1] [BIRTH_DATE#104815,DEATH_DATE#104820,EXTERNAL_DEATH_PROCESS_ID#104821,GENDER#104816,INHOSPITAL_DEATH_DATE#104818,INHOSPITAL_DEATH_CODE#104819,RAWTOHEX(PATIENT_ID)#104814,PSEUDO#104817] PushedFilters: [], ReadSchema: struct<BIRTH_DATE:timestamp,DEATH_DATE:timestamp,EXTERNAL_DEATH_PROCESS_ID:decimal(38,0),GENDER:s...
WholeStageCodegen (1)
== Physical Plan ==
Execute InsertIntoHadoopFsRelationCommand (4)
+- WriteFiles (3)
+- * Project (2)
+- * Scan JDBCRelation((SELECT RAWTOHEX(PATIENT_ID), "BIRTH_DATE", "GENDER", "PSEUDO", "INHOSPITAL_DEATH_DATE", "INHOSPITAL_DEATH_CODE", "DEATH_DATE", "EXTERNAL_DEATH_PROCESS_ID" FROM "DTM_622"."PATIENT") x) [numPartitions=1] (1)
(1) Scan JDBCRelation((SELECT RAWTOHEX(PATIENT_ID), "BIRTH_DATE", "GENDER", "PSEUDO", "INHOSPITAL_DEATH_DATE", "INHOSPITAL_DEATH_CODE", "DEATH_DATE", "EXTERNAL_DEATH_PROCESS_ID" FROM "DTM_622"."PATIENT") x) [numPartitions=1] [codegen id : 1]
Output [8]: [BIRTH_DATE#104815, DEATH_DATE#104820, EXTERNAL_DEATH_PROCESS_ID#104821, GENDER#104816, INHOSPITAL_DEATH_DATE#104818, INHOSPITAL_DEATH_CODE#104819, RAWTOHEX(PATIENT_ID)#104814, PSEUDO#104817]
ReadSchema: struct<BIRTH_DATE:timestamp,DEATH_DATE:timestamp,EXTERNAL_DEATH_PROCESS_ID:decimal(38,0),GENDER:string,INHOSPITAL_DEATH_DATE:timestamp,INHOSPITAL_DEATH_CODE:string,RAWTOHEX(PATIENT_ID):string,PSEUDO:string>
(2) Project [codegen id : 1]
Output [8]: [BIRTH_DATE#104815 AS BIRTH_DATE_3334#104870, DEATH_DATE#104820 AS DEATH_DATE_3339#104871, cast(EXTERNAL_DEATH_PROCESS_ID#104821 as int) AS EXTERNAL_DEATH__3340#104872, GENDER#104816 AS GENDER_3335#104873, INHOSPITAL_DEATH_DATE#104818 AS INHOSPITAL_DEAT_3337#104874, INHOSPITAL_DEATH_CODE#104819 AS INHOSPITAL_DEAT_3338#104875, RAWTOHEX(PATIENT_ID)#104814 AS PATIENT_ID_3333#104876, PSEUDO#104817 AS PSEUDO_3336#104877]
Input [8]: [BIRTH_DATE#104815, DEATH_DATE#104820, EXTERNAL_DEATH_PROCESS_ID#104821, GENDER#104816, INHOSPITAL_DEATH_DATE#104818, INHOSPITAL_DEATH_CODE#104819, RAWTOHEX(PATIENT_ID)#104814, PSEUDO#104817]
(3) WriteFiles
Input [8]: [BIRTH_DATE_3334#104870, DEATH_DATE_3339#104871, EXTERNAL_DEATH__3340#104872, GENDER_3335#104873, INHOSPITAL_DEAT_3337#104874, INHOSPITAL_DEAT_3338#104875, PATIENT_ID_3333#104876, PSEUDO_3336#104877]
(4) Execute InsertIntoHadoopFsRelationCommand
Input: []
Arguments: file:/data/output/cache/parquet/uet/PATIENT_3332, false, Parquet, [path=file:///data/output/cache/parquet/uet/PATIENT_3332], Overwrite, [BIRTH_DATE_3334, DEATH_DATE_3339, EXTERNAL_DEATH__3340, GENDER_3335, INHOSPITAL_DEAT_3337, INHOSPITAL_DEAT_3338, PATIENT_ID_3333, PSEUDO_3336]