digraph G { subgraph clusterstage_763 { label="Stage 763"; 2637 [labelType="html" label="JDBCRDD [2637]<br>first at /opt/app/scheduler/jobs/batch_table_copy_job.py:182"]; subgraph cluster6005 { label="WholeStageCodegen (1)"; 2638 [labelType="html" label="MapPartitionsRDD [2638]<br>first at /opt/app/scheduler/jobs/batch_table_copy_job.py:182"]; } subgraph cluster6007 { label="mapPartitionsInternal"; 2639 [labelType="html" label="MapPartitionsRDD [2639]<br>first at /opt/app/scheduler/jobs/batch_table_copy_job.py:182"]; } subgraph cluster6008 { label="mapPartitionsInternal"; 2640 [labelType="html" label="*(1) Scan JDBCRelation((SELECT * FROM dbo.fact_cm_country_analysis WHERE bigid BETWEEN 1 AND 162) AS page) [numPartitions=1] [company_id#206726,reporting_year#206727,country_code#206728,country_name#206729,total_smelters#206730,conflict_free_count#206731,audit_committed_count#206732,undeterminable_count#206733,active_smelters#206734,minerals_list#206735,is_drc_covered#206736,etl_runtime#206737,bigid#206738L] PushedFilters: [], ReadSchema: struct<company_id:string,reporting_year:int,country_code:string,country_name:string,total_smelter...\n [2640] [Cached]<br>first at /opt/app/scheduler/jobs/batch_table_copy_job.py:182"]; } } 2637->2638; 2638->2639; 2639->2640; }