digraph G { subgraph clusterstage_37371 { label="Stage 37371"; 161233 [labelType="html" label="JDBCRDD [161233]<br>first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; 161305 [labelType="html" label="SQLExecutionRDD [161305]<br>first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; subgraph cluster388540 { label="Scan JDBCRelation((SELECT * FROM dbo.fact_trans_chain_po_detail WHERE bigid BETWEEN 20001 AND 30000) AS page) [numPartitions=1] "; 161234 [labelType="html" label="MapPartitionsRDD [161234]<br>first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; } subgraph cluster388541 { label="mapPartitionsInternal"; 161235 [labelType="html" label="MapPartitionsRDD [161235]<br>first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; } subgraph cluster388542 { label="mapPartitionsInternal"; 161236 [labelType="html" label="Scan JDBCRelation((SELECT * FROM dbo.fact_trans_chain_po_detail WHERE bigid BETWEEN 20001 AND 30000) AS page) [numPartitions=1] [po_item_product_code#15147883,po_item_product_name#15147884,transaction_id#15147885,buyer_gln#15147886,seller_gln#15147887,pod_division#15147888,pod_delivery_date#15147889,pod_product_item_id#15147890,pod_product_entity#15147891,po_number#15147892,product_item_id#15147893,product_entity#15147894,brand_context_id#15147895,po_division#15147896,po_delivery_date#15147897,row_id#15147898L,parent_row_id#15147899,chain_seq#15147900,tier#15147901,production_input_type#15147902,trans_create_ts#15147903,trans_update_ts#15147904,outbound_create_ts#15147905,outbound_supplier_code#15147906,... 111 more fields] PushedFilters: [], ReadSchema: struct<po_item_product_code:string,po_item_product_name:string,transaction_id:string,buyer_gln:st...\n [161236] [Cached]<br>first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; } subgraph cluster388691 { label="InMemoryTableScan"; 161301 [labelType="html" label="MapPartitionsRDD [161301]<br>first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; 161302 [labelType="html" label="MapPartitionsRDD [161302]<br>first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; 161303 [labelType="html" label="MapPartitionsRDD [161303]<br>first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; } subgraph cluster388689 { label="DeserializeToObject"; 161304 [labelType="html" label="MapPartitionsRDD [161304]<br>first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; } subgraph cluster388692 { label="mapPartitions"; 161306 [labelType="html" label="MapPartitionsRDD [161306]<br>first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; } } 161233->161234; 161234->161235; 161235->161236; 161236->161301; 161301->161302; 161302->161303; 161303->161304; 161304->161305; 161305->161306; }