digraph G {
subgraph clusterstage_34039 {
label="Stage 34039";
subgraph cluster361485 {
label="Exchange";
149637 [labelType="html" label="ShuffledRowRDD [149637] [Unordered]<br>count at <unknown>:0"];
}
subgraph cluster361486 {
label="mapPartitionsInternal";
149638 [labelType="html" label="MapPartitionsRDD [149638] [Unordered]<br>count at <unknown>:0"];
}
subgraph cluster361487 {
label="mapPartitionsInternal";
149639 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Exchange SinglePartition, REPARTITION_BY_NUM, [plan_id=4247782]\n +- Project [brand_context_id#14300060, staticinvoke(class org.apache.spark.sql.catalyst.util.CharVarcharCodegenUtils, StringType, readSidePadding, NetworkID#14300061, 64, true, false, true) AS NetworkID#14300104, Child_Node#14300062, Parent_id#14300063, supplier_id#14300064, preferrd_supplier_id#14300065, supplier_ref_id#14300066, supplier_uid#14300067, supplier_name#14300068, supplier_country#14300069, direct_indirect#14300070, source_type#14300071, product_name#14300072, tier#14300073, is_latest#14300074, is_latest_submitted#14300075, is_unknown_supplier#14300076, company_id#14300077, config_name#14300078, direct_supplier_name#14300079, launch_request_name#14300080, launch_config_ref#14300081, revision_version#14300082, submission_status#14300083, ... 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... [149639] [Cached] [Unordered]<br>count at <unknown>:0"];
}
subgraph cluster361813 {
label="InMemoryTableScan";
149764 [labelType="html" label="MapPartitionsRDD [149764] [Unordered]<br>javaToPython at <unknown>:0"];
149765 [labelType="html" label="MapPartitionsRDD [149765] [Unordered]<br>javaToPython at <unknown>:0"];
149766 [labelType="html" label="MapPartitionsRDD [149766] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361809 {
label="WholeStageCodegen (1)";
149767 [labelType="html" label="MapPartitionsRDD [149767] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361808 {
label="MapInPandas";
149768 [labelType="html" label="MapPartitionsRDD [149768] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361804 {
label="WholeStageCodegen (2)";
149769 [labelType="html" label="MapPartitionsRDD [149769] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361803 {
label="MapInPandas";
149770 [labelType="html" label="MapPartitionsRDD [149770] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361801 {
label="AdaptiveSparkPlan";
149771 [labelType="html" label="MapPartitionsRDD [149771] [Unordered]<br>javaToPython at <unknown>:0"];
149772 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- MapInPandas <lambda>(brand_context_id#14301956, owner_supplier_id#14301957, facility_id#14301832, source#14301958)#14301963, [brand_context_id#14301964, owner_supplier_id#14301965, facility_id#14301966, source#14301967], false\n +- Project [6ad063ee7c692062b1d40711 AS brand_context_id#14301956, supplier_id#14301830 AS owner_supplier_id#14301957, facility_id#14301832, declared AS source#14301958]\n +- Filter (((isnotnull(supplier_id#14301830) AND NOT (supplier_id#14301830 = )) AND isnotnull(facility_id#14301832)) AND NOT (facility_id#14301832 = ))\n +- MapInPandas <lambda>(node_id#14300149, brand_context_id#14300060, supplier_id#14301801, preferrd_supplier_id#14301802, facility_id#14301803, preferrd_facility_id#14301804, value_process#14301805, product#14301806, material_name#14301807, subcontractor_id#14301808, is_subcontractor#14301752, is_unknown_supplier#14300076, is_unknown_facility#14300094, is_unknown_subcontractor#14300101, NetworkID#14300104, Child... [149772] [Cached] [Unordered]<br>javaToPython at <unknown>:0"];
}
}
149637->149638;
149638->149639;
149639->149764;
149764->149765;
149765->149766;
149766->149767;
149767->149768;
149768->149769;
149769->149770;
149770->149771;
149771->149772;
}
149636,149637
149639
149772