digraph G {
subgraph clusterstage_41756 {
label="Stage 41756";
subgraph cluster432229 {
label="Exchange";
183212 [labelType="html" label="ShuffledRowRDD [183212] [Unordered]<br>count at <unknown>:0"];
}
subgraph cluster432230 {
label="mapPartitionsInternal";
183213 [labelType="html" label="MapPartitionsRDD [183213] [Unordered]<br>count at <unknown>:0"];
}
subgraph cluster432231 {
label="mapPartitionsInternal";
183214 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Exchange SinglePartition, REPARTITION_BY_NUM, [plan_id=4527772]\n +- Project [brand_context_id#16689487, staticinvoke(class org.apache.spark.sql.catalyst.util.CharVarcharCodegenUtils, StringType, readSidePadding, NetworkID#16689488, 64, true, false, true) AS NetworkID#16689531, Child_Node#16689489, Parent_id#16689490, supplier_id#16689491, preferrd_supplier_id#16689492, supplier_ref_id#16689493, supplier_uid#16689494, supplier_name#16689495, supplier_country#16689496, direct_indirect#16689497, source_type#16689498, product_name#16689499, tier#16689500, is_latest#16689501, is_latest_submitted#16689502, is_unknown_supplier#16689503, company_id#16689504, config_name#16689505, direct_supplier_name#16689506, launch_request_name#16689507, launch_config_ref#16689508, revision_version#16689509, submission_status#16689510, ... 23 more fields]\n +- Scan JDBCRelation((\nSELECT\n c.brand_context_id,\n c.NetworkID,\n c.Child_Node,\n c.Parent_id,\n ISNULL(c.supplier_i... [183214] [Cached] [Unordered]<br>count at <unknown>:0"];
}
subgraph cluster432377 {
label="InMemoryTableScan";
183264 [labelType="html" label="MapPartitionsRDD [183264] [Unordered]<br>javaToPython at <unknown>:0"];
183265 [labelType="html" label="MapPartitionsRDD [183265] [Unordered]<br>javaToPython at <unknown>:0"];
183266 [labelType="html" label="MapPartitionsRDD [183266] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster432368 {
label="WholeStageCodegen (3)";
183267 [labelType="html" label="MapPartitionsRDD [183267] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster432367 {
label="MapInPandas";
183268 [labelType="html" label="MapPartitionsRDD [183268] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster432359 {
label="WholeStageCodegen (4)";
183269 [labelType="html" label="MapPartitionsRDD [183269] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster432321 {
label="AdaptiveSparkPlan";
183270 [labelType="html" label="MapPartitionsRDD [183270] [Unordered]<br>javaToPython at <unknown>:0"];
183271 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [supplier_id#16692296, preferrd_supplier_id#16692297, supplier_uid#16692298, name#16692299, brand_context_id#16692300, country#16692301, state#16692302, city#16692303, region#16692304, status#16692305, is_unknown#16692306, source_evidence#16692307, first_created_date#16692465]\n +- SortMergeJoin [supplier_id#16692296], [supplier_id#16689242], LeftOuter\n :- Sort [supplier_id#16692296 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(supplier_id#16692296, 10), ENSURE_REQUIREMENTS, [plan_id=4527890]\n : +- MapInPandas <lambda>(supplier_id#16692271, preferrd_supplier_id#16692272, supplier_uid#16692273, name#16692274, brand_context_id#16692275, country#16692276, state#16692277, city#16692278, region#16692279, status#16692280, is_unknown#16692281, source_evidence#16692282)#16692295, [supplier_id#16692296, preferrd_supplier_id#16692297, supplier_uid#16692298, name#16692299, brand_context_id#16692300, country#16692301, state#16692302, city... [183271] [Cached] [Unordered]<br>javaToPython at <unknown>:0"];
}
}
183212->183213;
183213->183214;
183214->183264;
183264->183265;
183265->183266;
183266->183267;
183267->183268;
183268->183269;
183269->183270;
183270->183271;
}
183211,183212
183214
183271