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: 155<br>number of dynamic part: 0<br>written output: 19.5 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), \"ID_MVT\", \"ID_SEJ\", \"ID_PAT\", \"UNIT\", \"ACTIVITY\", \"IN_DATE\", \"OUT_DATE\" FROM \"DTM_261\".\"VISIT_UNIT\") x) [numPartitions=1] </b><br><br>number of output rows: 155"];
}
1->0;
3->1;
4->3;
}
5
Execute InsertIntoHadoopFsRelationCommand file:/data/output/cache/parquet/uet/VISIT_UNIT_2958, false, Parquet, [path=file:///data/output/cache/parquet/uet/VISIT_UNIT_2958], Overwrite, [ACTIVITY_2966, ID_MVT_2962, ID_PAT_2964, ID_SEJ_2963, IN_DATE_2967, OUT_DATE_2968, PATIENT_ID_2961, UNIT_2965, VISIT_ID_2960, VISIT_UNIT_ID_2959]
WriteFiles
Project [ACTIVITY#63450 AS ACTIVITY_2966#63514, staticinvoke(class org.apache.spark.sql.catalyst.util.CharVarcharCodegenUtils, StringType, readSidePadding, ID_MVT#63446, 20, true, false, true) AS ID_MVT_2962#63515, cast(ID_PAT#63448 as int) AS ID_PAT_2964#63516, cast(ID_SEJ#63447 as int) AS ID_SEJ_2963#63517, IN_DATE#63451 AS IN_DATE_2967#63518, OUT_DATE#63452 AS OUT_DATE_2968#63519, RAWTOHEX(PATIENT_ID)#63445 AS PATIENT_ID_2961#63520, UNIT#63449 AS UNIT_2965#63521, RAWTOHEX(VISIT_ID)#63444 AS VISIT_ID_2960#63522, RAWTOHEX(VISIT_UNIT_ID)#63443 AS VISIT_UNIT_ID_2959#63523]
Scan JDBCRelation((SELECT RAWTOHEX(VISIT_UNIT_ID), RAWTOHEX(VISIT_ID), RAWTOHEX(PATIENT_ID), "ID_MVT", "ID_SEJ", "ID_PAT", "UNIT", "ACTIVITY", "IN_DATE", "OUT_DATE" FROM "DTM_261"."VISIT_UNIT") x) [numPartitions=1] [ACTIVITY#63450,ID_MVT#63446,ID_PAT#63448,ID_SEJ#63447,IN_DATE#63451,OUT_DATE#63452,RAWTOHEX(PATIENT_ID)#63445,UNIT#63449,RAWTOHEX(VISIT_ID)#63444,RAWTOHEX(VISIT_UNIT_ID)#63443] PushedFilters: [], ReadSchema: struct<ACTIVITY:string,ID_MVT:string,ID_PAT:decimal(38,0),ID_SEJ:decimal(38,0),IN_DATE:timestamp,...
WholeStageCodegen (1)
== Physical Plan ==
Execute InsertIntoHadoopFsRelationCommand (4)
+- WriteFiles (3)
+- * Project (2)
+- * Scan JDBCRelation((SELECT RAWTOHEX(VISIT_UNIT_ID), RAWTOHEX(VISIT_ID), RAWTOHEX(PATIENT_ID), "ID_MVT", "ID_SEJ", "ID_PAT", "UNIT", "ACTIVITY", "IN_DATE", "OUT_DATE" FROM "DTM_261"."VISIT_UNIT") x) [numPartitions=1] (1)
(1) Scan JDBCRelation((SELECT RAWTOHEX(VISIT_UNIT_ID), RAWTOHEX(VISIT_ID), RAWTOHEX(PATIENT_ID), "ID_MVT", "ID_SEJ", "ID_PAT", "UNIT", "ACTIVITY", "IN_DATE", "OUT_DATE" FROM "DTM_261"."VISIT_UNIT") x) [numPartitions=1] [codegen id : 1]
Output [10]: [ACTIVITY#63450, ID_MVT#63446, ID_PAT#63448, ID_SEJ#63447, IN_DATE#63451, OUT_DATE#63452, RAWTOHEX(PATIENT_ID)#63445, UNIT#63449, RAWTOHEX(VISIT_ID)#63444, RAWTOHEX(VISIT_UNIT_ID)#63443]
ReadSchema: struct<ACTIVITY:string,ID_MVT:string,ID_PAT:decimal(38,0),ID_SEJ:decimal(38,0),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 [10]: [ACTIVITY#63450 AS ACTIVITY_2966#63514, staticinvoke(class org.apache.spark.sql.catalyst.util.CharVarcharCodegenUtils, StringType, readSidePadding, ID_MVT#63446, 20, true, false, true) AS ID_MVT_2962#63515, cast(ID_PAT#63448 as int) AS ID_PAT_2964#63516, cast(ID_SEJ#63447 as int) AS ID_SEJ_2963#63517, IN_DATE#63451 AS IN_DATE_2967#63518, OUT_DATE#63452 AS OUT_DATE_2968#63519, RAWTOHEX(PATIENT_ID)#63445 AS PATIENT_ID_2961#63520, UNIT#63449 AS UNIT_2965#63521, RAWTOHEX(VISIT_ID)#63444 AS VISIT_ID_2960#63522, RAWTOHEX(VISIT_UNIT_ID)#63443 AS VISIT_UNIT_ID_2959#63523]
Input [10]: [ACTIVITY#63450, ID_MVT#63446, ID_PAT#63448, ID_SEJ#63447, IN_DATE#63451, OUT_DATE#63452, RAWTOHEX(PATIENT_ID)#63445, UNIT#63449, RAWTOHEX(VISIT_ID)#63444, RAWTOHEX(VISIT_UNIT_ID)#63443]
(3) WriteFiles
Input [10]: [ACTIVITY_2966#63514, ID_MVT_2962#63515, ID_PAT_2964#63516, ID_SEJ_2963#63517, IN_DATE_2967#63518, OUT_DATE_2968#63519, PATIENT_ID_2961#63520, UNIT_2965#63521, VISIT_ID_2960#63522, VISIT_UNIT_ID_2959#63523]
(4) Execute InsertIntoHadoopFsRelationCommand
Input: []
Arguments: file:/data/output/cache/parquet/uet/VISIT_UNIT_2958, false, Parquet, [path=file:///data/output/cache/parquet/uet/VISIT_UNIT_2958], Overwrite, [ACTIVITY_2966, ID_MVT_2962, ID_PAT_2964, ID_SEJ_2963, IN_DATE_2967, OUT_DATE_2968, PATIENT_ID_2961, UNIT_2965, VISIT_ID_2960, VISIT_UNIT_ID_2959]