digraph G {
subgraph clusterstage_41784 {
label="Stage 41784";
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 cluster432557 {
label="InMemoryTableScan";
183339 [labelType="html" label="MapPartitionsRDD [183339] [Unordered]<br>javaToPython at <unknown>:0"];
183340 [labelType="html" label="MapPartitionsRDD [183340] [Unordered]<br>javaToPython at <unknown>:0"];
183341 [labelType="html" label="MapPartitionsRDD [183341] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster432553 {
label="WholeStageCodegen (1)";
183342 [labelType="html" label="MapPartitionsRDD [183342] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster432552 {
label="MapInPandas";
183343 [labelType="html" label="MapPartitionsRDD [183343] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster432548 {
label="WholeStageCodegen (2)";
183344 [labelType="html" label="MapPartitionsRDD [183344] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster432547 {
label="MapInPandas";
183345 [labelType="html" label="MapPartitionsRDD [183345] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster432545 {
label="AdaptiveSparkPlan";
183346 [labelType="html" label="MapPartitionsRDD [183346] [Unordered]<br>javaToPython at <unknown>:0"];
183347 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- MapInPandas <lambda>(brand_context_id#16691383, owner_supplier_id#16691384, facility_id#16691259, source#16691385)#16691390, [brand_context_id#16691391, owner_supplier_id#16691392, facility_id#16691393, source#16691394], false\n +- Project [6ad063ee7c692062b1d40711 AS brand_context_id#16691383, supplier_id#16691257 AS owner_supplier_id#16691384, facility_id#16691259, declared AS source#16691385]\n +- Filter (((isnotnull(supplier_id#16691257) AND NOT (supplier_id#16691257 = )) AND isnotnull(facility_id#16691259)) AND NOT (facility_id#16691259 = ))\n +- MapInPandas <lambda>(node_id#16689576, brand_context_id#16689487, supplier_id#16691228, preferrd_supplier_id#16691229, facility_id#16691230, preferrd_facility_id#16691231, value_process#16691232, product#16691233, material_name#16691234, subcontractor_id#16691235, is_subcontractor#16691179, is_unknown_supplier#16689503, is_unknown_facility#16689521, is_unknown_subcontractor#16689528, NetworkID#16689531, Child... [183347] [Cached] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster432690 {
label="InMemoryTableScan";
183408 [labelType="html" label="MapPartitionsRDD [183408] [Unordered]<br>$anonfun$withThreadLocalCaptured$1 at <unknown>:0"];
183409 [labelType="html" label="MapPartitionsRDD [183409] [Unordered]<br>$anonfun$withThreadLocalCaptured$1 at <unknown>:0"];
183410 [labelType="html" label="MapPartitionsRDD [183410] [Unordered]<br>$anonfun$withThreadLocalCaptured$1 at <unknown>:0"];
}
subgraph cluster432685 {
label="WholeStageCodegen (1)";
183411 [labelType="html" label="MapPartitionsRDD [183411] [Unordered]<br>$anonfun$withThreadLocalCaptured$1 at <unknown>:0"];
}
subgraph cluster432684 {
label="BroadcastExchange";
183412 [labelType="html" label="MapPartitionsRDD [183412] [Unordered]<br>$anonfun$withThreadLocalCaptured$1 at <unknown>:0"];
}
}
183212->183213;
183213->183214;
183214->183339;
183339->183340;
183340->183341;
183341->183342;
183342->183343;
183343->183344;
183344->183345;
183345->183346;
183346->183347;
183347->183408;
183408->183409;
183409->183410;
183410->183411;
183411->183412;
}
183211,183212
183214
183347