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: 7 ms<br>number of output rows: 1,382<br>number of dynamic part: 0<br>written output: 127.1 KiB"];
1 [labelType="html" label="<br><b>WriteFiles</b><br><br>"];
subgraph cluster2 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 116 ms";
3 [labelType="html" label="<br><b>Project</b><br><br>"];
4 [labelType="html" label="<b>Scan JDBCRelation((SELECT RAWTOHEX(VISIT_UNIT_ID), RAWTOHEX(VISIT_ID), RAWTOHEX(PATIENT_ID), \"UNIT\", \"ACTIVITY\", \"IN_DATE\", \"OUT_DATE\" FROM \"DTM_622\".\"VISIT_UNIT\") x) [numPartitions=1] </b><br><br>number of output rows: 1,382"];
}
1->0;
3->1;
4->3;
}
5
Execute InsertIntoHadoopFsRelationCommand file:/data/output/cache/parquet/uet/VISIT_UNIT_3357, false, Parquet, [path=file:///data/output/cache/parquet/uet/VISIT_UNIT_3357], Overwrite, [ACTIVITY_3362, IN_DATE_3363, OUT_DATE_3364, PATIENT_ID_3360, UNIT_3361, VISIT_ID_3359, VISIT_UNIT_ID_3358]
WriteFiles
Project [ACTIVITY#61775 AS ACTIVITY_3362#61820, IN_DATE#61776 AS IN_DATE_3363#61821, OUT_DATE#61777 AS OUT_DATE_3364#61822, RAWTOHEX(PATIENT_ID)#61773 AS PATIENT_ID_3360#61823, UNIT#61774 AS UNIT_3361#61824, RAWTOHEX(VISIT_ID)#61772 AS VISIT_ID_3359#61825, RAWTOHEX(VISIT_UNIT_ID)#61771 AS VISIT_UNIT_ID_3358#61826]
Scan JDBCRelation((SELECT RAWTOHEX(VISIT_UNIT_ID), RAWTOHEX(VISIT_ID), RAWTOHEX(PATIENT_ID), "UNIT", "ACTIVITY", "IN_DATE", "OUT_DATE" FROM "DTM_622"."VISIT_UNIT") x) [numPartitions=1] [ACTIVITY#61775,IN_DATE#61776,OUT_DATE#61777,RAWTOHEX(PATIENT_ID)#61773,UNIT#61774,RAWTOHEX(VISIT_ID)#61772,RAWTOHEX(VISIT_UNIT_ID)#61771] PushedFilters: [], ReadSchema: struct<ACTIVITY:string,IN_DATE:timestamp,OUT_DATE:timestamp,RAWTOHEX(PATIENT_ID):string,UNIT:stri...
WholeStageCodegen (1)
== Physical Plan ==
Execute InsertIntoHadoopFsRelationCommand (4)
+- WriteFiles (3)
+- * Project (2)
+- * Scan JDBCRelation((SELECT RAWTOHEX(VISIT_UNIT_ID), RAWTOHEX(VISIT_ID), RAWTOHEX(PATIENT_ID), "UNIT", "ACTIVITY", "IN_DATE", "OUT_DATE" FROM "DTM_622"."VISIT_UNIT") x) [numPartitions=1] (1)
(1) Scan JDBCRelation((SELECT RAWTOHEX(VISIT_UNIT_ID), RAWTOHEX(VISIT_ID), RAWTOHEX(PATIENT_ID), "UNIT", "ACTIVITY", "IN_DATE", "OUT_DATE" FROM "DTM_622"."VISIT_UNIT") x) [numPartitions=1] [codegen id : 1]
Output [7]: [ACTIVITY#61775, IN_DATE#61776, OUT_DATE#61777, RAWTOHEX(PATIENT_ID)#61773, UNIT#61774, RAWTOHEX(VISIT_ID)#61772, RAWTOHEX(VISIT_UNIT_ID)#61771]
ReadSchema: struct<ACTIVITY:string,IN_DATE:timestamp,OUT_DATE:timestamp,RAWTOHEX(PATIENT_ID):string,UNIT:string,RAWTOHEX(VISIT_ID):string,RAWTOHEX(VISIT_UNIT_ID):string>
(2) Project [codegen id : 1]
Output [7]: [ACTIVITY#61775 AS ACTIVITY_3362#61820, IN_DATE#61776 AS IN_DATE_3363#61821, OUT_DATE#61777 AS OUT_DATE_3364#61822, RAWTOHEX(PATIENT_ID)#61773 AS PATIENT_ID_3360#61823, UNIT#61774 AS UNIT_3361#61824, RAWTOHEX(VISIT_ID)#61772 AS VISIT_ID_3359#61825, RAWTOHEX(VISIT_UNIT_ID)#61771 AS VISIT_UNIT_ID_3358#61826]
Input [7]: [ACTIVITY#61775, IN_DATE#61776, OUT_DATE#61777, RAWTOHEX(PATIENT_ID)#61773, UNIT#61774, RAWTOHEX(VISIT_ID)#61772, RAWTOHEX(VISIT_UNIT_ID)#61771]
(3) WriteFiles
Input [7]: [ACTIVITY_3362#61820, IN_DATE_3363#61821, OUT_DATE_3364#61822, PATIENT_ID_3360#61823, UNIT_3361#61824, VISIT_ID_3359#61825, VISIT_UNIT_ID_3358#61826]
(4) Execute InsertIntoHadoopFsRelationCommand
Input: []
Arguments: file:/data/output/cache/parquet/uet/VISIT_UNIT_3357, false, Parquet, [path=file:///data/output/cache/parquet/uet/VISIT_UNIT_3357], Overwrite, [ACTIVITY_3362, IN_DATE_3363, OUT_DATE_3364, PATIENT_ID_3360, UNIT_3361, VISIT_ID_3359, VISIT_UNIT_ID_3358]