digraph G {
0 [labelType="html" label="<b>Execute InsertIntoHadoopFsRelationCommand</b><br><br>task commit time: 21 ms<br>number of written files: 1<br>job commit time: 34 ms<br>number of output rows: 3<br>number of dynamic part: 0<br>written output: 9.9 KiB"];
1 [labelType="html" label="<br><b>WriteFiles</b><br><br>"];
subgraph cluster2 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 133 ms";
3 [labelType="html" label="<br><b>Project</b><br><br>"];
4 [labelType="html" label="<b>Scan JDBCRelation(\"SDATA_YEWU\".\"t_gas_product_inventory\") [numPartitions=1] </b><br><br>number of output rows: 3"];
}
1->0;
3->1;
4->3;
}
5
Execute InsertIntoHadoopFsRelationCommand file:/home/sdata/tomcat/webapps/storage_area/private/config/123456789/3979448040819712/asset/datafile/tmp/4869587244289024, false, Parquet, [path=/home/sdata/tomcat/webapps/storage_area/private/config/123456789/3979448040819712/asset/datafile/tmp/4869587244289024], Overwrite, [data_id, office_id, create_member, create_time, create_member_ip_address, last_modifier, last_modify_time, last_modifier_ip_address, location_description, location_id, location, stock_age, total_inventory, entry_time, alarm_low_value_indicator, warning_low_value_indicator, warning_high_value_indicator, alarm_high_value_indicator, alarm_low_value, warning_low_value, warning_high_value, alarm_high_value, product_specifications, level_strength, ... 8 more fields]
WriteFiles
Project [data_id#8600, office_id#8601, create_member#8602, create_time#8603, create_member_ip_address#8604, last_modifier#8605, last_modify_time#8606, last_modifier_ip_address#8607, location_description#8608, location_id#8609, location#8610, cast(stock_age#8611 as decimal(38,0)) AS stock_age#10979, cast(total_inventory#8612 as decimal(38,2)) AS total_inventory#10980, entry_time#8613, alarm_low_value_indicator#8614, warning_low_value_indicator#8615, warning_high_value_indicator#8616, alarm_high_value_indicator#8617, cast(alarm_low_value#8618 as decimal(38,0)) AS alarm_low_value#10986, cast(warning_low_value#8619 as decimal(38,0)) AS warning_low_value#10987, cast(warning_high_value#8620 as decimal(38,0)) AS warning_high_value#10988, cast(alarm_high_value#8621 as decimal(38,0)) AS alarm_high_value#10989, product_specifications#8622, level_strength#8623, ... 8 more fields]
Scan JDBCRelation("SDATA_YEWU"."t_gas_product_inventory") [numPartitions=1] [data_id#8600,office_id#8601,create_member#8602,create_time#8603,create_member_ip_address#8604,last_modifier#8605,last_modify_time#8606,last_modifier_ip_address#8607,location_description#8608,location_id#8609,location#8610,stock_age#8611,total_inventory#8612,entry_time#8613,alarm_low_value_indicator#8614,warning_low_value_indicator#8615,warning_high_value_indicator#8616,alarm_high_value_indicator#8617,alarm_low_value#8618,warning_low_value#8619,warning_high_value#8620,alarm_high_value#8621,product_specifications#8622,level_strength#8623,... 7 more fields] PushedFilters: [], ReadSchema: struct<data_id:string,office_id:string,create_member:string,create_time:timestamp,create_member_i...
WholeStageCodegen (1)
== Physical Plan ==
Execute InsertIntoHadoopFsRelationCommand (4)
+- WriteFiles (3)
+- * Project (2)
+- * Scan JDBCRelation("SDATA_YEWU"."t_gas_product_inventory") [numPartitions=1] (1)
(1) Scan JDBCRelation("SDATA_YEWU"."t_gas_product_inventory") [numPartitions=1] [codegen id : 1]
Output [31]: [data_id#8600, office_id#8601, create_member#8602, create_time#8603, create_member_ip_address#8604, last_modifier#8605, last_modify_time#8606, last_modifier_ip_address#8607, location_description#8608, location_id#8609, location#8610, stock_age#8611, total_inventory#8612, entry_time#8613, alarm_low_value_indicator#8614, warning_low_value_indicator#8615, warning_high_value_indicator#8616, alarm_high_value_indicator#8617, alarm_low_value#8618, warning_low_value#8619, warning_high_value#8620, alarm_high_value#8621, product_specifications#8622, level_strength#8623, level_bulk_density#8624, level_grade#8625, bagging_mark#8626, pallet_overview#8627, pallet_spec#8628, pallet_material#8629, del_flag#8630]
ReadSchema: struct<data_id:string,office_id:string,create_member:string,create_time:timestamp,create_member_ip_address:string,last_modifier:string,last_modify_time:timestamp,last_modifier_ip_address:string,location_description:string,location_id:string,location:string,stock_age:int,total_inventory:decimal(10,2),entry_time:timestamp,alarm_low_value_indicator:string,warning_low_value_indicator:string,warning_high_value_indicator:string,alarm_high_value_indicator:string,alarm_low_value:int,warning_low_value:int,warning_high_value:int,alarm_high_value:int,product_specifications:string,level_strength:string,level_bulk_density:string,level_grade:string,bagging_mark:string,pallet_overview:string,pallet_spec:string,pallet_material:string,del_flag:string>
(2) Project [codegen id : 1]
Output [32]: [data_id#8600, office_id#8601, create_member#8602, create_time#8603, create_member_ip_address#8604, last_modifier#8605, last_modify_time#8606, last_modifier_ip_address#8607, location_description#8608, location_id#8609, location#8610, cast(stock_age#8611 as decimal(38,0)) AS stock_age#10979, cast(total_inventory#8612 as decimal(38,2)) AS total_inventory#10980, entry_time#8613, alarm_low_value_indicator#8614, warning_low_value_indicator#8615, warning_high_value_indicator#8616, alarm_high_value_indicator#8617, cast(alarm_low_value#8618 as decimal(38,0)) AS alarm_low_value#10986, cast(warning_low_value#8619 as decimal(38,0)) AS warning_low_value#10987, cast(warning_high_value#8620 as decimal(38,0)) AS warning_high_value#10988, cast(alarm_high_value#8621 as decimal(38,0)) AS alarm_high_value#10989, product_specifications#8622, level_strength#8623, level_bulk_density#8624, level_grade#8625, bagging_mark#8626, pallet_overview#8627, pallet_spec#8628, pallet_material#8629, del_flag#8630, cast(datediff(2025-03-06, cast(entry_time#8613 as date)) as decimal(38,0)) AS kl#10999]
Input [31]: [data_id#8600, office_id#8601, create_member#8602, create_time#8603, create_member_ip_address#8604, last_modifier#8605, last_modify_time#8606, last_modifier_ip_address#8607, location_description#8608, location_id#8609, location#8610, stock_age#8611, total_inventory#8612, entry_time#8613, alarm_low_value_indicator#8614, warning_low_value_indicator#8615, warning_high_value_indicator#8616, alarm_high_value_indicator#8617, alarm_low_value#8618, warning_low_value#8619, warning_high_value#8620, alarm_high_value#8621, product_specifications#8622, level_strength#8623, level_bulk_density#8624, level_grade#8625, bagging_mark#8626, pallet_overview#8627, pallet_spec#8628, pallet_material#8629, del_flag#8630]
(3) WriteFiles
Input [32]: [data_id#8600, office_id#8601, create_member#8602, create_time#8603, create_member_ip_address#8604, last_modifier#8605, last_modify_time#8606, last_modifier_ip_address#8607, location_description#8608, location_id#8609, location#8610, stock_age#10979, total_inventory#10980, entry_time#8613, alarm_low_value_indicator#8614, warning_low_value_indicator#8615, warning_high_value_indicator#8616, alarm_high_value_indicator#8617, alarm_low_value#10986, warning_low_value#10987, warning_high_value#10988, alarm_high_value#10989, product_specifications#8622, level_strength#8623, level_bulk_density#8624, level_grade#8625, bagging_mark#8626, pallet_overview#8627, pallet_spec#8628, pallet_material#8629, del_flag#8630, kl#10999]
(4) Execute InsertIntoHadoopFsRelationCommand
Input: []
Arguments: file:/home/sdata/tomcat/webapps/storage_area/private/config/123456789/3979448040819712/asset/datafile/tmp/4869587244289024, false, Parquet, [path=/home/sdata/tomcat/webapps/storage_area/private/config/123456789/3979448040819712/asset/datafile/tmp/4869587244289024], Overwrite, [data_id, office_id, create_member, create_time, create_member_ip_address, last_modifier, last_modify_time, last_modifier_ip_address, location_description, location_id, location, stock_age, total_inventory, entry_time, alarm_low_value_indicator, warning_low_value_indicator, warning_high_value_indicator, alarm_high_value_indicator, alarm_low_value, warning_low_value, warning_high_value, alarm_high_value, product_specifications, level_strength, ... 8 more fields]