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: 17 ms<br>number of output rows: 1<br>number of dynamic part: 0<br>written output: 7.4 KiB"];
1 [labelType="html" label="<br><b>WriteFiles</b><br><br>"];
subgraph cluster2 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 44 ms";
3 [labelType="html" label="<b>Scan JDBCRelation(\"SDATA_YEWU\".\"t_materials_list\") [numPartitions=1] </b><br><br>number of output rows: 1"];
}
1->0;
3->1;
}
4
Execute InsertIntoHadoopFsRelationCommand file:/home/sdata/warehouse/53ed4d53-3f8f-496f-9657-c9e8f0399d4f, false, Parquet, [path=/home/sdata/warehouse/53ed4d53-3f8f-496f-9657-c9e8f0399d4f], Overwrite, [data_id, material_code, material_name, model, unit, whether_audited, specification, brand, bom_number, material_number_erp, material_description, material_note, quantity, warning_content, warehouse_date, storage_age, whether_age_warning, del_flag, create_member, office_id, create_time, create_member_ip_address, last_modifier, last_modify_time, last_modify_ip_address]
WriteFiles
Scan JDBCRelation("SDATA_YEWU"."t_materials_list") [numPartitions=1] [data_id#15886,material_code#15887,material_name#15888,model#15889,unit#15890,whether_audited#15891,specification#15892,brand#15893,bom_number#15894,material_number_erp#15895,material_description#15896,material_note#15897,quantity#15898,warning_content#15899,warehouse_date#15900,storage_age#15901,whether_age_warning#15902,del_flag#15903,create_member#15904,office_id#15905,create_time#15906,create_member_ip_address#15907,last_modifier#15908,last_modify_time#15909,last_modify_ip_address#15910] PushedFilters: [], ReadSchema: struct<data_id:string,material_code:string,material_name:string,model:string,unit:string,whether_...
WholeStageCodegen (1)
== Physical Plan ==
Execute InsertIntoHadoopFsRelationCommand (3)
+- WriteFiles (2)
+- * Scan JDBCRelation("SDATA_YEWU"."t_materials_list") [numPartitions=1] (1)
(1) Scan JDBCRelation("SDATA_YEWU"."t_materials_list") [numPartitions=1] [codegen id : 1]
Output [25]: [data_id#15886, material_code#15887, material_name#15888, model#15889, unit#15890, whether_audited#15891, specification#15892, brand#15893, bom_number#15894, material_number_erp#15895, material_description#15896, material_note#15897, quantity#15898, warning_content#15899, warehouse_date#15900, storage_age#15901, whether_age_warning#15902, del_flag#15903, create_member#15904, office_id#15905, create_time#15906, create_member_ip_address#15907, last_modifier#15908, last_modify_time#15909, last_modify_ip_address#15910]
ReadSchema: struct<data_id:string,material_code:string,material_name:string,model:string,unit:string,whether_audited:string,specification:string,brand:string,bom_number:string,material_number_erp:string,material_description:string,material_note:string,quantity:int,warning_content:string,warehouse_date:timestamp,storage_age:int,whether_age_warning:string,del_flag:string,create_member:string,office_id:string,create_time:timestamp,create_member_ip_address:string,last_modifier:string,last_modify_time:timestamp,last_modify_ip_address:string>
(2) WriteFiles
Input [25]: [data_id#15886, material_code#15887, material_name#15888, model#15889, unit#15890, whether_audited#15891, specification#15892, brand#15893, bom_number#15894, material_number_erp#15895, material_description#15896, material_note#15897, quantity#15898, warning_content#15899, warehouse_date#15900, storage_age#15901, whether_age_warning#15902, del_flag#15903, create_member#15904, office_id#15905, create_time#15906, create_member_ip_address#15907, last_modifier#15908, last_modify_time#15909, last_modify_ip_address#15910]
(3) Execute InsertIntoHadoopFsRelationCommand
Input: []
Arguments: file:/home/sdata/warehouse/53ed4d53-3f8f-496f-9657-c9e8f0399d4f, false, Parquet, [path=/home/sdata/warehouse/53ed4d53-3f8f-496f-9657-c9e8f0399d4f], Overwrite, [data_id, material_code, material_name, model, unit, whether_audited, specification, brand, bom_number, material_number_erp, material_description, material_note, quantity, warning_content, warehouse_date, storage_age, whether_age_warning, del_flag, create_member, office_id, create_time, create_member_ip_address, last_modifier, last_modify_time, last_modify_ip_address]