digraph G {
subgraph clusterstage_34060 {
label="Stage 34060";
149829 [labelType="html" label="PythonRDD [149829]<br>RDD at PythonRDD.scala:53"];
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 cluster361699 {
label="InMemoryTableScan";
149719 [labelType="html" label="MapPartitionsRDD [149719] [Unordered]<br>javaToPython at <unknown>:0"];
149720 [labelType="html" label="MapPartitionsRDD [149720] [Unordered]<br>javaToPython at <unknown>:0"];
149721 [labelType="html" label="MapPartitionsRDD [149721] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361691 {
label="WholeStageCodegen (3)";
149722 [labelType="html" label="MapPartitionsRDD [149722] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361690 {
label="MapInPandas";
149723 [labelType="html" label="MapPartitionsRDD [149723] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361682 {
label="WholeStageCodegen (4)";
149724 [labelType="html" label="MapPartitionsRDD [149724] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361644 {
label="AdaptiveSparkPlan";
149725 [labelType="html" label="MapPartitionsRDD [149725] [Unordered]<br>javaToPython at <unknown>:0"];
149726 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [facility_id#14303014, facility_uid#14303015, name#14303016, brand_context_id#14303017, owner_supplier_id#14303018, country#14303019, state#14303020, city#14303021, region#14303022, is_unknown#14303023, value_processes#14303024, materials#14303025, first_created_date#14303869]\n +- SortMergeJoin [facility_id#14303014], [facility_id#14299829], LeftOuter\n :- Sort [facility_id#14303014 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(facility_id#14303014, 10), ENSURE_REQUIREMENTS, [plan_id=4247959]\n : +- MapInPandas <lambda>(facility_id#14302989, facility_uid#14302990, name#14302991, brand_context_id#14302992, owner_supplier_id#14302993, country#14302994, state#14302995, city#14302996, region#14302997, is_unknown#14302998, value_processes#14302999, materials#14303000)#14303013, [facility_id#14303014, facility_uid#14303015, name#14303016, brand_context_id#14303017, owner_supplier_id#14303018, country#14303019, state#14303020, city#14... [149726] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361907 {
label="InMemoryTableScan";
149809 [labelType="html" label="MapPartitionsRDD [149809] [Unordered]<br>javaToPython at <unknown>:0"];
149810 [labelType="html" label="MapPartitionsRDD [149810] [Unordered]<br>javaToPython at <unknown>:0"];
149811 [labelType="html" label="MapPartitionsRDD [149811] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361896 {
label="WholeStageCodegen (2)";
149812 [labelType="html" label="MapPartitionsRDD [149812] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361882 {
label="AdaptiveSparkPlan";
149813 [labelType="html" label="MapPartitionsRDD [149813] [Unordered]<br>javaToPython at <unknown>:0"];
149814 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [facility_id#14303014 AS entity_id#14312382, brand_context_id#14303017, dim_id#14312376, raw_level#14312377 AS level#14312383, CASE WHEN (cast(raw_level#14312377 as double) >= 4.2) THEN Extreme WHEN (cast(raw_level#14312377 as double) >= 3.4) THEN High WHEN (cast(raw_level#14312377 as double) >= 2.6) THEN Moderate WHEN (cast(raw_level#14312377 as double) >= 1.8) THEN Medium WHEN (cast(raw_level#14312377 as double) >= 1.0) THEN Low ELSE Unknown END AS level_band#14312384, active AS status#14312385, 2026-10-18T10:50:16.324932+00:00 AS listed_at#14312386, 2026-10-18T10:50:16.324932+00:00 AS assessed_at#14312387, null AS matched_entity#14312388, null AS match_pct#14312389, null AS match_source#14312390, null AS threshold#14312391, null AS kharon_id#14312392]\n +- Filter (isnotnull(raw_level#14312377) AND NOT (raw_level#14312377 = ))\n +- Generate stack(13, risk_child_labor, cast(Child_Labor#14184896 as string), risk_forced_labor, cast(Forced_Labor#14184895 as... [149814] [Cached] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361933 {
label="parallelize";
149828 [labelType="html" label="ParallelCollectionRDD [149828]<br>readRDDFromFile at PythonRDD.scala:289"];
}
subgraph cluster361934 {
label="mapPartitions";
149830 [labelType="html" label="MapPartitionsRDD [149830]<br>mapPartitions at SerDeUtil.scala:117"];
}
subgraph cluster361935 {
label="map";
149831 [labelType="html" label="MapPartitionsRDD [149831]<br>map at SerDeUtil.scala:69"];
}
subgraph cluster361936 {
label="mapPartitions";
149832 [labelType="html" label="MapPartitionsRDD [149832]<br>applySchemaToPythonRDD at <unknown>:0"];
}
subgraph cluster361967 {
label="InMemoryTableScan";
149838 [labelType="html" label="MapPartitionsRDD [149838] [Unordered]<br>javaToPython at <unknown>:0"];
149839 [labelType="html" label="MapPartitionsRDD [149839] [Unordered]<br>javaToPython at <unknown>:0"];
149840 [labelType="html" label="MapPartitionsRDD [149840] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361962 {
label="WholeStageCodegen (2)";
149841 [labelType="html" label="MapPartitionsRDD [149841] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361968 {
label="WholeStageCodegen (3)";
149842 [labelType="html" label="MapPartitionsRDD [149842]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361961 {
label="Union";
149843 [labelType="html" label="UnionRDD [149843] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361953 {
label="WholeStageCodegen (4)";
149844 [labelType="html" label="MapPartitionsRDD [149844] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361938 {
label="AdaptiveSparkPlan";
149845 [labelType="html" label="MapPartitionsRDD [149845] [Unordered]<br>javaToPython at <unknown>:0"];
149846 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [facility_id#14314109, dim_id#14312376, lvl#14314110, sid#14314114]\n +- BroadcastHashJoin [facility_id#14314109], [facility_id#14301966], Inner, BuildRight, false\n :- Union\n : :- Project [entity_id#14312382 AS facility_id#14314109, dim_id#14312376, cast(level#14312383 as double) AS lvl#14314110]\n : : +- Filter ((isnotnull(dim_id#14312376) AND NOT (dim_id#14312376 = risk_overall)) AND isnotnull(entity_id#14312382))\n : : +- InMemoryTableScan [dim_id#14312376, entity_id#14312382, level#14312383], [isnotnull(dim_id#14312376), NOT (dim_id#14312376 = risk_overall), isnotnull(entity_id#14312382)]\n : : +- InMemoryRelation [entity_id#14312382, brand_context_id#14303017, dim_id#14312376, level#14312383, level_band#14312384, status#14312385, listed_at#14312386, assessed_at#14312387, matched_entity#14312388, match_pct#14312389, match_source#14312390, threshold#14312391, kharon_id#14312392], StorageLevel(disk, memory, deseriali... [149846] [Cached] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster362014 {
label="InMemoryTableScan";
149861 [labelType="html" label="MapPartitionsRDD [149861] [Unordered]<br>javaToPython at <unknown>:0"];
149862 [labelType="html" label="MapPartitionsRDD [149862] [Unordered]<br>javaToPython at <unknown>:0"];
149863 [labelType="html" label="MapPartitionsRDD [149863] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster362008 {
label="WholeStageCodegen (1)";
149864 [labelType="html" label="MapPartitionsRDD [149864] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster362007 {
label="Exchange";
149865 [labelType="html" label="MapPartitionsRDD [149865] [Unordered]<br>javaToPython at <unknown>:0"];
}
}
149637->149638;
149638->149639;
149639->149719;
149719->149720;
149720->149721;
149721->149722;
149722->149723;
149723->149724;
149724->149725;
149725->149726;
149726->149809;
149809->149810;
149810->149811;
149811->149812;
149812->149813;
149813->149814;
149828->149829;
149829->149830;
149830->149831;
149831->149832;
149814->149838;
149838->149839;
149839->149840;
149840->149841;
149832->149842;
149841->149843;
149842->149843;
149843->149844;
149844->149845;
149845->149846;
149846->149861;
149861->149862;
149862->149863;
149863->149864;
149864->149865;
}
149636,149637
149639
149814
149846