digraph G {
0 [labelType="html" label="<b>Execute InsertIntoHadoopFsRelationCommand</b><br><br>task commit time: 5 ms<br>number of written files: 1<br>job commit time: 8 ms<br>number of output rows: 1,382<br>number of dynamic part: 1<br>written output: 86.8 KiB"];
1 [labelType="html" label="<br><b>WriteFiles</b><br><br>"];
subgraph cluster2 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 259 ms";
3 [labelType="html" label="<b>Sort</b><br><br>sort time: 4 ms<br>peak memory: 64.1 MiB<br>spill size: 0.0 B"];
4 [labelType="html" label="<br><b>Project</b><br><br>"];
5 [labelType="html" label="<b>Scan JDBCRelation((SELECT \"VISIT_UNIT_ID\", \"VISIT_ID\", \"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->4;
}
6
Execute InsertIntoHadoopFsRelationCommand file:/data/input/depot/db/execution/CC228BF0_FE6C_40C8_A395_CACD62326678/extraction, false, [date_20f50d8ac05a11a370e750c0022c6c83#44285], Parquet, [__partition_columns=["date_20f50d8ac05a11a370e750c0022c6c83"], path=file:///data/input/depot/db/execution/CC228BF0_FE6C_40C8_A395_CACD62326678/extraction], Append, [VISIT_UNIT_ID, VISIT_ID, PATIENT_ID, UNIT, ACTIVITY, IN_DATE, OUT_DATE, date_20f50d8ac05a11a370e750c0022c6c83]
WriteFiles
Sort [date_20f50d8ac05a11a370e750c0022c6c83#44285 ASC NULLS FIRST], false, 0
Project [VISIT_UNIT_ID#44199, VISIT_ID#44200, PATIENT_ID#44201, UNIT#44202, ACTIVITY#44203, IN_DATE#44204, OUT_DATE#44205, 2026-02-20 08:21:14.075016 AS date_20f50d8ac05a11a370e750c0022c6c83#44285]
Scan JDBCRelation((SELECT "VISIT_UNIT_ID", "VISIT_ID", "PATIENT_ID", "UNIT", "ACTIVITY", "IN_DATE", "OUT_DATE" FROM "DTM_622"."VISIT_UNIT") x) [numPartitions=1] [VISIT_UNIT_ID#44199,VISIT_ID#44200,PATIENT_ID#44201,UNIT#44202,ACTIVITY#44203,IN_DATE#44204,OUT_DATE#44205] PushedFilters: [], ReadSchema: struct<VISIT_UNIT_ID:binary,VISIT_ID:binary,PATIENT_ID:binary,UNIT:string,ACTIVITY:string,IN_DATE...
WholeStageCodegen (1)
== Physical Plan ==
Execute InsertIntoHadoopFsRelationCommand (5)
+- WriteFiles (4)
+- * Sort (3)
+- * Project (2)
+- * Scan JDBCRelation((SELECT "VISIT_UNIT_ID", "VISIT_ID", "PATIENT_ID", "UNIT", "ACTIVITY", "IN_DATE", "OUT_DATE" FROM "DTM_622"."VISIT_UNIT") x) [numPartitions=1] (1)
(1) Scan JDBCRelation((SELECT "VISIT_UNIT_ID", "VISIT_ID", "PATIENT_ID", "UNIT", "ACTIVITY", "IN_DATE", "OUT_DATE" FROM "DTM_622"."VISIT_UNIT") x) [numPartitions=1] [codegen id : 1]
Output [7]: [VISIT_UNIT_ID#44199, VISIT_ID#44200, PATIENT_ID#44201, UNIT#44202, ACTIVITY#44203, IN_DATE#44204, OUT_DATE#44205]
ReadSchema: struct<VISIT_UNIT_ID:binary,VISIT_ID:binary,PATIENT_ID:binary,UNIT:string,ACTIVITY:string,IN_DATE:timestamp,OUT_DATE:timestamp>
(2) Project [codegen id : 1]
Output [8]: [VISIT_UNIT_ID#44199, VISIT_ID#44200, PATIENT_ID#44201, UNIT#44202, ACTIVITY#44203, IN_DATE#44204, OUT_DATE#44205, 2026-02-20 08:21:14.075016 AS date_20f50d8ac05a11a370e750c0022c6c83#44285]
Input [7]: [VISIT_UNIT_ID#44199, VISIT_ID#44200, PATIENT_ID#44201, UNIT#44202, ACTIVITY#44203, IN_DATE#44204, OUT_DATE#44205]
(3) Sort [codegen id : 1]
Input [8]: [VISIT_UNIT_ID#44199, VISIT_ID#44200, PATIENT_ID#44201, UNIT#44202, ACTIVITY#44203, IN_DATE#44204, OUT_DATE#44205, date_20f50d8ac05a11a370e750c0022c6c83#44285]
Arguments: [date_20f50d8ac05a11a370e750c0022c6c83#44285 ASC NULLS FIRST], false, 0
(4) WriteFiles
Input [8]: [VISIT_UNIT_ID#44199, VISIT_ID#44200, PATIENT_ID#44201, UNIT#44202, ACTIVITY#44203, IN_DATE#44204, OUT_DATE#44205, date_20f50d8ac05a11a370e750c0022c6c83#44285]
(5) Execute InsertIntoHadoopFsRelationCommand
Input: []
Arguments: file:/data/input/depot/db/execution/CC228BF0_FE6C_40C8_A395_CACD62326678/extraction, false, [date_20f50d8ac05a11a370e750c0022c6c83#44285], Parquet, [__partition_columns=["date_20f50d8ac05a11a370e750c0022c6c83"], path=file:///data/input/depot/db/execution/CC228BF0_FE6C_40C8_A395_CACD62326678/extraction], Append, [VISIT_UNIT_ID, VISIT_ID, PATIENT_ID, UNIT, ACTIVITY, IN_DATE, OUT_DATE, date_20f50d8ac05a11a370e750c0022c6c83]