digraph G {
subgraph clusterstage_39698 {
label="Stage 39698";
subgraph cluster403988 {
label="Exchange";
169610 [labelType="html" label="ShuffledRowRDD [169610] [Unordered]<br>count at <unknown>:0"];
}
subgraph cluster403989 {
label="mapPartitionsInternal";
169611 [labelType="html" label="MapPartitionsRDD [169611] [Unordered]<br>count at <unknown>:0"];
}
subgraph cluster403990 {
label="mapPartitionsInternal";
169612 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Exchange SinglePartition, REPARTITION_BY_NUM, [plan_id=3316750]\n +- Project [brand_context_id#20322539, staticinvoke(class org.apache.spark.sql.catalyst.util.CharVarcharCodegenUtils, StringType, readSidePadding, NetworkID#20322540, 64, true, false, true) AS NetworkID#20322583, Child_Node#20322541, Parent_id#20322542, supplier_id#20322543, preferrd_supplier_id#20322544, supplier_ref_id#20322545, supplier_uid#20322546, supplier_name#20322547, supplier_country#20322548, direct_indirect#20322549, source_type#20322550, product_name#20322551, tier#20322552, is_latest#20322553, is_latest_submitted#20322554, is_unknown_supplier#20322555, company_id#20322556, config_name#20322557, direct_supplier_name#20322558, launch_request_name#20322559, launch_config_ref#20322560, revision_version#20322561, submission_status#20322562, ... 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... [169612] [Cached] [Unordered]<br>count at <unknown>:0"];
}
subgraph cluster404592 {
label="InMemoryTableScan";
169851 [labelType="html" label="MapPartitionsRDD [169851] [Unordered]<br>javaToPython at <unknown>:0"];
169852 [labelType="html" label="MapPartitionsRDD [169852] [Unordered]<br>javaToPython at <unknown>:0"];
169853 [labelType="html" label="MapPartitionsRDD [169853] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster404588 {
label="WholeStageCodegen (1)";
169854 [labelType="html" label="MapPartitionsRDD [169854] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster404587 {
label="MapInPandas";
169855 [labelType="html" label="MapPartitionsRDD [169855] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster404583 {
label="WholeStageCodegen (2)";
169856 [labelType="html" label="MapPartitionsRDD [169856] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster404582 {
label="MapInPandas";
169857 [labelType="html" label="MapPartitionsRDD [169857] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster404580 {
label="AdaptiveSparkPlan";
169858 [labelType="html" label="MapPartitionsRDD [169858] [Unordered]<br>javaToPython at <unknown>:0"];
169859 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- MapInPandas <lambda>(brand_context_id#20326963, owner_supplier_id#20326964, facility_id#20326096, source#20326986)#20326993, [brand_context_id#20326994, owner_supplier_id#20326995, facility_id#20326996, source#20326997], false\n +- Project [6a8bf0ac7cc171297135c303 AS brand_context_id#20326963, supplier_id#20326094 AS owner_supplier_id#20326964, facility_id#20326096, declared AS source#20326986]\n +- Filter (((isnotnull(supplier_id#20326094) AND NOT (supplier_id#20326094 = )) AND isnotnull(facility_id#20326096)) AND NOT (facility_id#20326096 = ))\n +- MapInPandas <lambda>(node_id#20322629, brand_context_id#20322539, supplier_id#20325940, preferrd_supplier_id#20325941, facility_id#20325942, preferrd_facility_id#20325961, value_process#20325962, product#20325963, material_name#20325964, subcontractor_id#20325984, is_subcontractor#20325889, is_unknown_supplier#20322555, is_unknown_facility#20322573, is_unknown_subcontractor#20322580, NetworkID#20322583, Child... [169859] [Cached] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster405149 {
label="InMemoryTableScan";
170071 [labelType="html" label="MapPartitionsRDD [170071] [Unordered]<br>$anonfun$withThreadLocalCaptured$1 at <unknown>:0"];
170072 [labelType="html" label="MapPartitionsRDD [170072] [Unordered]<br>$anonfun$withThreadLocalCaptured$1 at <unknown>:0"];
170073 [labelType="html" label="MapPartitionsRDD [170073] [Unordered]<br>$anonfun$withThreadLocalCaptured$1 at <unknown>:0"];
}
subgraph cluster405142 {
label="WholeStageCodegen (1)";
170074 [labelType="html" label="MapPartitionsRDD [170074] [Unordered]<br>$anonfun$withThreadLocalCaptured$1 at <unknown>:0"];
}
subgraph cluster405141 {
label="BroadcastExchange";
170075 [labelType="html" label="MapPartitionsRDD [170075] [Unordered]<br>$anonfun$withThreadLocalCaptured$1 at <unknown>:0"];
}
}
169610->169611;
169611->169612;
169612->169851;
169851->169852;
169852->169853;
169853->169854;
169854->169855;
169855->169856;
169856->169857;
169857->169858;
169858->169859;
169859->170071;
170071->170072;
170072->170073;
170073->170074;
170074->170075;
}
169601,169610
169612
169859