digraph G {
subgraph clusterstage_26722 {
label="Stage 26722";
subgraph cluster294752 {
label="Exchange";
117625 [labelType="html" label="ShuffledRowRDD [117625] [Unordered]<br>count at <unknown>:0"];
}
subgraph cluster294753 {
label="mapPartitionsInternal";
117626 [labelType="html" label="MapPartitionsRDD [117626] [Unordered]<br>count at <unknown>:0"];
}
subgraph cluster294754 {
label="mapPartitionsInternal";
117627 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Exchange SinglePartition, REPARTITION_BY_NUM, [plan_id=3993705]\n +- Project [brand_context_id#12010729, staticinvoke(class org.apache.spark.sql.catalyst.util.CharVarcharCodegenUtils, StringType, readSidePadding, NetworkID#12010730, 64, true, false, true) AS NetworkID#12010773, Child_Node#12010731, Parent_id#12010732, supplier_id#12010733, preferrd_supplier_id#12010734, supplier_ref_id#12010735, supplier_uid#12010736, supplier_name#12010737, supplier_country#12010738, direct_indirect#12010739, source_type#12010740, product_name#12010741, tier#12010742, is_latest#12010743, is_latest_submitted#12010744, is_unknown_supplier#12010745, company_id#12010746, config_name#12010747, direct_supplier_name#12010748, launch_request_name#12010749, launch_config_ref#12010750, revision_version#12010751, submission_status#12010752, ... 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... [117627] [Cached] [Unordered]<br>count at <unknown>:0"];
}
subgraph cluster295070 {
label="InMemoryTableScan";
117742 [labelType="html" label="MapPartitionsRDD [117742] [Unordered]<br>javaToPython at <unknown>:0"];
117743 [labelType="html" label="MapPartitionsRDD [117743] [Unordered]<br>javaToPython at <unknown>:0"];
117744 [labelType="html" label="MapPartitionsRDD [117744] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster295058 {
label="WholeStageCodegen (4)";
117745 [labelType="html" label="MapPartitionsRDD [117745] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster295057 {
label="MapInPandas";
117746 [labelType="html" label="MapPartitionsRDD [117746] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster295049 {
label="WholeStageCodegen (5)";
117747 [labelType="html" label="MapPartitionsRDD [117747] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster295008 {
label="AdaptiveSparkPlan";
117748 [labelType="html" label="MapPartitionsRDD [117748] [Unordered]<br>javaToPython at <unknown>:0"];
117749 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [supplier_id#12015636, supplier_uid#12015637, name#12015638, brand_context_id#12015639, country#12015640, state#12015641, city#12015642, region#12015643, status#12015644, is_unknown#12015645, source_evidence#12015646, first_created_date#12015658]\n +- SortMergeJoin [supplier_id#12015636], [supplier_id#12015661], LeftOuter\n :- Sort [supplier_id#12015636 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(supplier_id#12015636, 10), ENSURE_REQUIREMENTS, [plan_id=3993958]\n : +- MapInPandas <lambda>(supplier_id#12015613, supplier_uid#12015614, name#12015615, brand_context_id#12015616, country#12015617, state#12015618, city#12015619, region#12015620, status#12015621, is_unknown#12015622, source_evidence#12015623)#12015635, [supplier_id#12015636, supplier_uid#12015637, name#12015638, brand_context_id#12015639, country#12015640, state#12015641, city#12015642, region#12015643, status#12015644, is_unknown#12015645, source_evidence#12015646], ... [117749] [Cached] [Unordered]<br>javaToPython at <unknown>:0"];
}
}
117625->117626;
117626->117627;
117627->117742;
117742->117743;
117743->117744;
117744->117745;
117745->117746;
117746->117747;
117747->117748;
117748->117749;
}
117624,117625
117627
117749