digraph G {
0 [labelType="html" label="<b>Execute InsertIntoHadoopFsRelationCommand</b><br><br>task commit time: 2 ms<br>number of written files: 1<br>job commit time: 8 ms<br>number of output rows: 50<br>number of dynamic part: 0<br>written output: 2.9 KiB"];
1 [labelType="html" label="<br><b>WriteFiles</b><br><br>"];
subgraph cluster2 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 121 ms";
3 [labelType="html" label="<br><b>Project</b><br><br>"];
4 [labelType="html" label="<b>Scan JDBCRelation((SELECT \"PATIENT_ID\", \"ID_PAT\", \"BIRTH_DATE\", \"GENDER\", \"PSEUDO\", \"INHOSPITAL_DEATH_DATE\", \"INHOSPITAL_DEATH_CODE\", \"DEATH_DATE\", \"EXTERNAL_DEATH_PROCESS_ID\" FROM \"DTM_261\".\"PATIENT\") x) [numPartitions=1] </b><br><br>number of output rows: 50"];
}
1->0;
3->1;
4->3;
}
5
Execute InsertIntoHadoopFsRelationCommand file:/data/output/cache/parquet/uet/PATIENT_2930, false, Parquet, [path=file:///data/output/cache/parquet/uet/PATIENT_2930], Overwrite, [BIRTH_DATE_2933, DEATH_DATE_2938, EXTERNAL_DEATH__2939, GENDER_2934, ID_PAT_2932, INHOSPITAL_DEAT_2936, INHOSPITAL_DEAT_2937, PATIENT_ID_2931, PSEUDO_2935]
WriteFiles
Project [BIRTH_DATE#3641 AS BIRTH_DATE_2933#3702, DEATH_DATE#3646 AS DEATH_DATE_2938#3703, cast(EXTERNAL_DEATH_PROCESS_ID#3647 as int) AS EXTERNAL_DEATH__2939#3704, GENDER#3642 AS GENDER_2934#3705, cast(ID_PAT#3640 as int) AS ID_PAT_2932#3706, INHOSPITAL_DEATH_DATE#3644 AS INHOSPITAL_DEAT_2936#3707, INHOSPITAL_DEATH_CODE#3645 AS INHOSPITAL_DEAT_2937#3708, null AS PATIENT_ID_2931#3709, PSEUDO#3643 AS PSEUDO_2935#3710]
Scan JDBCRelation((SELECT "PATIENT_ID", "ID_PAT", "BIRTH_DATE", "GENDER", "PSEUDO", "INHOSPITAL_DEATH_DATE", "INHOSPITAL_DEATH_CODE", "DEATH_DATE", "EXTERNAL_DEATH_PROCESS_ID" FROM "DTM_261"."PATIENT") x) [numPartitions=1] [BIRTH_DATE#3641,DEATH_DATE#3646,EXTERNAL_DEATH_PROCESS_ID#3647,GENDER#3642,ID_PAT#3640,INHOSPITAL_DEATH_DATE#3644,INHOSPITAL_DEATH_CODE#3645,PSEUDO#3643] 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 "PATIENT_ID", "ID_PAT", "BIRTH_DATE", "GENDER", "PSEUDO", "INHOSPITAL_DEATH_DATE", "INHOSPITAL_DEATH_CODE", "DEATH_DATE", "EXTERNAL_DEATH_PROCESS_ID" FROM "DTM_261"."PATIENT") x) [numPartitions=1] (1)
(1) Scan JDBCRelation((SELECT "PATIENT_ID", "ID_PAT", "BIRTH_DATE", "GENDER", "PSEUDO", "INHOSPITAL_DEATH_DATE", "INHOSPITAL_DEATH_CODE", "DEATH_DATE", "EXTERNAL_DEATH_PROCESS_ID" FROM "DTM_261"."PATIENT") x) [numPartitions=1] [codegen id : 1]
Output [8]: [BIRTH_DATE#3641, DEATH_DATE#3646, EXTERNAL_DEATH_PROCESS_ID#3647, GENDER#3642, ID_PAT#3640, INHOSPITAL_DEATH_DATE#3644, INHOSPITAL_DEATH_CODE#3645, PSEUDO#3643]
ReadSchema: struct<BIRTH_DATE:timestamp,DEATH_DATE:timestamp,EXTERNAL_DEATH_PROCESS_ID:decimal(38,0),GENDER:string,ID_PAT:decimal(38,0),INHOSPITAL_DEATH_DATE:timestamp,INHOSPITAL_DEATH_CODE:string,PSEUDO:string>
(2) Project [codegen id : 1]
Output [9]: [BIRTH_DATE#3641 AS BIRTH_DATE_2933#3702, DEATH_DATE#3646 AS DEATH_DATE_2938#3703, cast(EXTERNAL_DEATH_PROCESS_ID#3647 as int) AS EXTERNAL_DEATH__2939#3704, GENDER#3642 AS GENDER_2934#3705, cast(ID_PAT#3640 as int) AS ID_PAT_2932#3706, INHOSPITAL_DEATH_DATE#3644 AS INHOSPITAL_DEAT_2936#3707, INHOSPITAL_DEATH_CODE#3645 AS INHOSPITAL_DEAT_2937#3708, null AS PATIENT_ID_2931#3709, PSEUDO#3643 AS PSEUDO_2935#3710]
Input [8]: [BIRTH_DATE#3641, DEATH_DATE#3646, EXTERNAL_DEATH_PROCESS_ID#3647, GENDER#3642, ID_PAT#3640, INHOSPITAL_DEATH_DATE#3644, INHOSPITAL_DEATH_CODE#3645, PSEUDO#3643]
(3) WriteFiles
Input [9]: [BIRTH_DATE_2933#3702, DEATH_DATE_2938#3703, EXTERNAL_DEATH__2939#3704, GENDER_2934#3705, ID_PAT_2932#3706, INHOSPITAL_DEAT_2936#3707, INHOSPITAL_DEAT_2937#3708, PATIENT_ID_2931#3709, PSEUDO_2935#3710]
(4) Execute InsertIntoHadoopFsRelationCommand
Input: []
Arguments: file:/data/output/cache/parquet/uet/PATIENT_2930, false, Parquet, [path=file:///data/output/cache/parquet/uet/PATIENT_2930], Overwrite, [BIRTH_DATE_2933, DEATH_DATE_2938, EXTERNAL_DEATH__2939, GENDER_2934, ID_PAT_2932, INHOSPITAL_DEAT_2936, INHOSPITAL_DEAT_2937, PATIENT_ID_2931, PSEUDO_2935]