digraph G {
subgraph clusterstage_39781 {
label="Stage 39781";
subgraph cluster405718 {
label="Exchange";
170287 [labelType="html" label="ShuffledRowRDD [170287] [Unordered]<br>count at <unknown>:0"];
}
subgraph cluster405719 {
label="mapPartitionsInternal";
170288 [labelType="html" label="MapPartitionsRDD [170288] [Unordered]<br>count at <unknown>:0"];
}
subgraph cluster405720 {
label="mapPartitionsInternal";
170289 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Exchange SinglePartition, REPARTITION_BY_NUM, [plan_id=3325998]\n +- Project [brand_context_id#20377588, staticinvoke(class org.apache.spark.sql.catalyst.util.CharVarcharCodegenUtils, StringType, readSidePadding, NetworkID#20377589, 64, true, false, true) AS NetworkID#20377632, Child_Node#20377590, Parent_id#20377591, supplier_id#20377592, preferrd_supplier_id#20377593, supplier_ref_id#20377594, supplier_uid#20377595, supplier_name#20377596, supplier_country#20377597, direct_indirect#20377598, source_type#20377599, product_name#20377600, tier#20377601, is_latest#20377602, is_latest_submitted#20377603, is_unknown_supplier#20377604, company_id#20377605, config_name#20377606, direct_supplier_name#20377607, launch_request_name#20377608, launch_config_ref#20377609, revision_version#20377610, submission_status#20377611, ... 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... [170289] [Cached] [Unordered]<br>count at <unknown>:0"];
}
subgraph cluster406014 {
label="InMemoryTableScan";
170397 [labelType="html" label="MapPartitionsRDD [170397] [Unordered]<br>javaToPython at <unknown>:0"];
170398 [labelType="html" label="MapPartitionsRDD [170398] [Unordered]<br>javaToPython at <unknown>:0"];
170399 [labelType="html" label="MapPartitionsRDD [170399] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster406002 {
label="WholeStageCodegen (4)";
170400 [labelType="html" label="MapPartitionsRDD [170400] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster406001 {
label="MapInPandas";
170401 [labelType="html" label="MapPartitionsRDD [170401] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster405993 {
label="WholeStageCodegen (5)";
170402 [labelType="html" label="MapPartitionsRDD [170402] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster405952 {
label="AdaptiveSparkPlan";
170403 [labelType="html" label="MapPartitionsRDD [170403] [Unordered]<br>javaToPython at <unknown>:0"];
170404 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [supplier_id#20382495, supplier_uid#20382496, name#20382497, brand_context_id#20382498, country#20382499, state#20382500, city#20382501, region#20382502, status#20382503, is_unknown#20382504, source_evidence#20382505, first_created_date#20382517]\n +- SortMergeJoin [supplier_id#20382495], [supplier_id#20382520], LeftOuter\n :- Sort [supplier_id#20382495 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(supplier_id#20382495, 10), ENSURE_REQUIREMENTS, [plan_id=3326251]\n : +- MapInPandas <lambda>(supplier_id#20382472, supplier_uid#20382473, name#20382474, brand_context_id#20382475, country#20382476, state#20382477, city#20382478, region#20382479, status#20382480, is_unknown#20382481, source_evidence#20382482)#20382494, [supplier_id#20382495, supplier_uid#20382496, name#20382497, brand_context_id#20382498, country#20382499, state#20382500, city#20382501, region#20382502, status#20382503, is_unknown#20382504, source_evidence#20382505], ... [170404] [Cached] [Unordered]<br>javaToPython at <unknown>:0"];
}
}
170287->170288;
170288->170289;
170289->170397;
170397->170398;
170398->170399;
170399->170400;
170400->170401;
170401->170402;
170402->170403;
170403->170404;
}
170286,170287
170289
170404