digraph G {
subgraph clusterstage_26724 {
label="Stage 26724";
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 cluster295093 {
label="InMemoryTableScan";
117756 [labelType="html" label="MapPartitionsRDD [117756] [Unordered]<br>javaToPython at <unknown>:0"];
117757 [labelType="html" label="MapPartitionsRDD [117757] [Unordered]<br>javaToPython at <unknown>:0"];
117758 [labelType="html" label="MapPartitionsRDD [117758] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster295089 {
label="WholeStageCodegen (1)";
117759 [labelType="html" label="MapPartitionsRDD [117759] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster295088 {
label="MapInPandas";
117760 [labelType="html" label="MapPartitionsRDD [117760] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster295084 {
label="WholeStageCodegen (2)";
117761 [labelType="html" label="MapPartitionsRDD [117761] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster295083 {
label="MapInPandas";
117762 [labelType="html" label="MapPartitionsRDD [117762] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster295081 {
label="AdaptiveSparkPlan";
117763 [labelType="html" label="MapPartitionsRDD [117763] [Unordered]<br>javaToPython at <unknown>:0"];
117764 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- MapInPandas <lambda>(brand_context_id#12012625, owner_supplier_id#12012626, facility_id#12012501, source#12012627)#12012632, [brand_context_id#12012633, owner_supplier_id#12012634, facility_id#12012635, source#12012636], false\n +- Project [6aacf5861a41b434b2a90520 AS brand_context_id#12012625, supplier_id#12012499 AS owner_supplier_id#12012626, facility_id#12012501, declared AS source#12012627]\n +- Filter (((isnotnull(supplier_id#12012499) AND NOT (supplier_id#12012499 = )) AND isnotnull(facility_id#12012501)) AND NOT (facility_id#12012501 = ))\n +- MapInPandas <lambda>(node_id#12010818, brand_context_id#12010729, supplier_id#12012470, preferrd_supplier_id#12012471, facility_id#12012472, preferrd_facility_id#12012473, value_process#12012474, product#12012475, material_name#12012476, subcontractor_id#12012477, is_subcontractor#12012421, is_unknown_supplier#12010745, is_unknown_facility#12010763, is_unknown_subcontractor#12010770, NetworkID#12010773, Child... [117764] [Cached] [Unordered]<br>javaToPython at <unknown>:0"];
}
}
117625->117626;
117626->117627;
117627->117756;
117756->117757;
117757->117758;
117758->117759;
117759->117760;
117760->117761;
117761->117762;
117762->117763;
117763->117764;
}
117624,117625
117627
117764