digraph G {
subgraph clusterstage_34044 {
label="Stage 34044";
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 cluster361633 {
label="InMemoryTableScan";
149689 [labelType="html" label="MapPartitionsRDD [149689] [Unordered]<br>javaToPython at <unknown>:0"];
149690 [labelType="html" label="MapPartitionsRDD [149690] [Unordered]<br>javaToPython at <unknown>:0"];
149691 [labelType="html" label="MapPartitionsRDD [149691] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361624 {
label="WholeStageCodegen (3)";
149692 [labelType="html" label="MapPartitionsRDD [149692] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361623 {
label="MapInPandas";
149693 [labelType="html" label="MapPartitionsRDD [149693] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361615 {
label="WholeStageCodegen (4)";
149694 [labelType="html" label="MapPartitionsRDD [149694] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361577 {
label="AdaptiveSparkPlan";
149695 [labelType="html" label="MapPartitionsRDD [149695] [Unordered]<br>javaToPython at <unknown>:0"];
149696 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [supplier_id#14302869, preferrd_supplier_id#14302870, supplier_uid#14302871, name#14302872, brand_context_id#14302873, country#14302874, state#14302875, city#14302876, region#14302877, status#14302878, is_unknown#14302879, source_evidence#14302880, first_created_date#14303038]\n +- SortMergeJoin [supplier_id#14302869], [supplier_id#14299815], LeftOuter\n :- Sort [supplier_id#14302869 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(supplier_id#14302869, 10), ENSURE_REQUIREMENTS, [plan_id=4247900]\n : +- MapInPandas <lambda>(supplier_id#14302844, preferrd_supplier_id#14302845, supplier_uid#14302846, name#14302847, brand_context_id#14302848, country#14302849, state#14302850, city#14302851, region#14302852, status#14302853, is_unknown#14302854, source_evidence#14302855)#14302868, [supplier_id#14302869, preferrd_supplier_id#14302870, supplier_uid#14302871, name#14302872, brand_context_id#14302873, country#14302874, state#14302875, city... [149696] [Cached] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361790 {
label="InMemoryTableScan";
149750 [labelType="html" label="MapPartitionsRDD [149750] [Unordered]<br>javaToPython at <unknown>:0"];
149751 [labelType="html" label="MapPartitionsRDD [149751] [Unordered]<br>javaToPython at <unknown>:0"];
149752 [labelType="html" label="MapPartitionsRDD [149752] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361781 {
label="WholeStageCodegen (4)";
149753 [labelType="html" label="MapPartitionsRDD [149753] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361780 {
label="MapInPandas";
149754 [labelType="html" label="MapPartitionsRDD [149754] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361772 {
label="WholeStageCodegen (5)";
149755 [labelType="html" label="MapPartitionsRDD [149755] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361723 {
label="AdaptiveSparkPlan";
149756 [labelType="html" label="MapPartitionsRDD [149756] [Unordered]<br>javaToPython at <unknown>:0"];
149757 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [supplier_id#14304967, supplier_uid#14304968, name#14304969, brand_context_id#14304970, country#14304971, state#14304972, city#14304973, region#14304974, status#14304975, is_unknown#14304976, source_evidence#14304977, first_created_date#14304989]\n +- SortMergeJoin [supplier_id#14304967], [supplier_id#14304992], LeftOuter\n :- Sort [supplier_id#14304967 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(supplier_id#14304967, 10), ENSURE_REQUIREMENTS, [plan_id=4248035]\n : +- MapInPandas <lambda>(supplier_id#14304944, supplier_uid#14304945, name#14304946, brand_context_id#14304947, country#14304948, state#14304949, city#14304950, region#14304951, status#14304952, is_unknown#14304953, source_evidence#14304954)#14304966, [supplier_id#14304967, supplier_uid#14304968, name#14304969, brand_context_id#14304970, country#14304971, state#14304972, city#14304973, region#14304974, status#14304975, is_unknown#14304976, source_evidence#14304977], ... [149757] [Cached] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361866 {
label="InMemoryTableScan";
149786 [labelType="html" label="MapPartitionsRDD [149786] [Unordered]<br>javaToPython at <unknown>:0"];
149787 [labelType="html" label="MapPartitionsRDD [149787] [Unordered]<br>javaToPython at <unknown>:0"];
149788 [labelType="html" label="MapPartitionsRDD [149788] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361862 {
label="WholeStageCodegen (2)";
149789 [labelType="html" label="MapPartitionsRDD [149789] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361871 {
label="InMemoryTableScan";
149790 [labelType="html" label="MapPartitionsRDD [149790] [Unordered]<br>javaToPython at <unknown>:0"];
149791 [labelType="html" label="MapPartitionsRDD [149791] [Unordered]<br>javaToPython at <unknown>:0"];
149792 [labelType="html" label="MapPartitionsRDD [149792] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361867 {
label="WholeStageCodegen (3)";
149793 [labelType="html" label="MapPartitionsRDD [149793] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361861 {
label="Union";
149794 [labelType="html" label="UnionRDD [149794] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361852 {
label="WholeStageCodegen (4)";
149795 [labelType="html" label="MapPartitionsRDD [149795] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361838 {
label="AdaptiveSparkPlan";
149796 [labelType="html" label="MapPartitionsRDD [149796] [Unordered]<br>javaToPython at <unknown>:0"];
149797 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [supplier_id#14302869 AS entity_id#14311522, brand_context_id#14302873, dim_id#14311516, raw_level#14311517 AS level#14311523, CASE WHEN (cast(raw_level#14311517 as double) >= 4.2) THEN Extreme WHEN (cast(raw_level#14311517 as double) >= 3.4) THEN High WHEN (cast(raw_level#14311517 as double) >= 2.6) THEN Moderate WHEN (cast(raw_level#14311517 as double) >= 1.8) THEN Medium WHEN (cast(raw_level#14311517 as double) >= 1.0) THEN Low ELSE Unknown END AS level_band#14311524, active AS status#14311525, 2026-10-18T10:50:16.324932+00:00 AS listed_at#14311526, 2026-10-18T10:50:16.324932+00:00 AS assessed_at#14311527, null AS matched_entity#14311528, null AS match_pct#14311529, null AS match_source#14311530, null AS threshold#14311531, null AS kharon_id#14311532]\n +- Filter (isnotnull(raw_level#14311517) AND NOT (raw_level#14311517 = ))\n +- Generate stack(13, risk_child_labor, cast(Child_Labor#14184896 as string), risk_forced_labor, cast(Forced_Labor#14184895 as... [149797] [Cached] [Unordered]<br>javaToPython at <unknown>:0"];
}
}
149637->149638;
149638->149639;
149639->149689;
149689->149690;
149690->149691;
149691->149692;
149692->149693;
149693->149694;
149694->149695;
149695->149696;
149639->149750;
149750->149751;
149751->149752;
149752->149753;
149753->149754;
149754->149755;
149755->149756;
149756->149757;
149696->149786;
149786->149787;
149787->149788;
149788->149789;
149757->149790;
149790->149791;
149791->149792;
149792->149793;
149789->149794;
149793->149794;
149794->149795;
149795->149796;
149796->149797;
}
149636,149637
149639
149696
149757
149797