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: 71 ms<br>number of output rows: 3<br>number of dynamic part: 0<br>written output: 9.5 KiB"];
1 [labelType="html" label="<br><b>WriteFiles</b><br><br>"];
subgraph cluster2 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 63 ms";
3 [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
Execute InsertIntoHadoopFsRelationCommand file:/home/sdata/warehouse/aadb097b-80d3-4f4e-a146-35b30f4f3a0c, false, Parquet, [path=/home/sdata/warehouse/aadb097b-80d3-4f4e-a146-35b30f4f3a0c], 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, ... 7 more fields]
WriteFiles
Scan JDBCRelation("SDATA_YEWU"."t_gas_product_inventory") [numPartitions=1] [data_id#11414,office_id#11415,create_member#11416,create_time#11417,create_member_ip_address#11418,last_modifier#11419,last_modify_time#11420,last_modifier_ip_address#11421,location_description#11422,location_id#11423,location#11424,stock_age#11425,total_inventory#11426,entry_time#11427,alarm_low_value_indicator#11428,warning_low_value_indicator#11429,warning_high_value_indicator#11430,alarm_high_value_indicator#11431,alarm_low_value#11432,warning_low_value#11433,warning_high_value#11434,alarm_high_value#11435,product_specifications#11436,level_strength#11437,... 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 (3)
+- WriteFiles (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#11414, office_id#11415, create_member#11416, create_time#11417, create_member_ip_address#11418, last_modifier#11419, last_modify_time#11420, last_modifier_ip_address#11421, location_description#11422, location_id#11423, location#11424, stock_age#11425, total_inventory#11426, entry_time#11427, alarm_low_value_indicator#11428, warning_low_value_indicator#11429, warning_high_value_indicator#11430, alarm_high_value_indicator#11431, alarm_low_value#11432, warning_low_value#11433, warning_high_value#11434, alarm_high_value#11435, product_specifications#11436, level_strength#11437, level_bulk_density#11438, level_grade#11439, bagging_mark#11440, pallet_overview#11441, pallet_spec#11442, pallet_material#11443, del_flag#11444]
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) WriteFiles
Input [31]: [data_id#11414, office_id#11415, create_member#11416, create_time#11417, create_member_ip_address#11418, last_modifier#11419, last_modify_time#11420, last_modifier_ip_address#11421, location_description#11422, location_id#11423, location#11424, stock_age#11425, total_inventory#11426, entry_time#11427, alarm_low_value_indicator#11428, warning_low_value_indicator#11429, warning_high_value_indicator#11430, alarm_high_value_indicator#11431, alarm_low_value#11432, warning_low_value#11433, warning_high_value#11434, alarm_high_value#11435, product_specifications#11436, level_strength#11437, level_bulk_density#11438, level_grade#11439, bagging_mark#11440, pallet_overview#11441, pallet_spec#11442, pallet_material#11443, del_flag#11444]
(3) Execute InsertIntoHadoopFsRelationCommand
Input: []
Arguments: file:/home/sdata/warehouse/aadb097b-80d3-4f4e-a146-35b30f4f3a0c, false, Parquet, [path=/home/sdata/warehouse/aadb097b-80d3-4f4e-a146-35b30f4f3a0c], 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, ... 7 more fields]