digraph G {
subgraph clusterstage_26651 {
label="Stage 26651";
117457 [labelType="html" label="PythonRDD [117457]<br>RDD at PythonRDD.scala:53"];
subgraph cluster293835 {
label="Exchange";
117253 [labelType="html" label="ShuffledRowRDD [117253] [Unordered]<br>count at <unknown>:0"];
}
subgraph cluster293836 {
label="mapPartitionsInternal";
117254 [labelType="html" label="MapPartitionsRDD [117254] [Unordered]<br>count at <unknown>:0"];
}
subgraph cluster293837 {
label="mapPartitionsInternal";
117255 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Exchange hashpartitioning(NetworkID#11981894, 2), REPARTITION_BY_NUM, [plan_id=3989029]\n +- Project [brand_context_id#11981850, staticinvoke(class org.apache.spark.sql.catalyst.util.CharVarcharCodegenUtils, StringType, readSidePadding, NetworkID#11981851, 64, true, false, true) AS NetworkID#11981894, Child_Node#11981852, Parent_id#11981853, supplier_id#11981854, preferrd_supplier_id#11981855, supplier_ref_id#11981856, supplier_uid#11981857, supplier_name#11981858, supplier_country#11981859, direct_indirect#11981860, source_type#11981861, product_name#11981862, tier#11981863, is_latest#11981864, is_latest_submitted#11981865, is_unknown_supplier#11981866, company_id#11981867, config_name#11981868, direct_supplier_name#11981869, launch_request_name#11981870, launch_config_ref#11981871, revision_version#11981872, submission_status#11981873, ... 23 more fields]\n +- Scan JDBCRelation((\nSELECT\n c.brand_context_id,\n c.NetworkID,\n c.Child_Node,\n c.Parent_id,... [117255] [Cached] [Unordered]<br>count at <unknown>:0"];
}
subgraph cluster294082 {
label="InMemoryTableScan";
117345 [labelType="html" label="MapPartitionsRDD [117345] [Unordered]<br>javaToPython at <unknown>:0"];
117346 [labelType="html" label="MapPartitionsRDD [117346] [Unordered]<br>javaToPython at <unknown>:0"];
117347 [labelType="html" label="MapPartitionsRDD [117347] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster294074 {
label="WholeStageCodegen (3)";
117348 [labelType="html" label="MapPartitionsRDD [117348] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster294073 {
label="MapInPandas";
117349 [labelType="html" label="MapPartitionsRDD [117349] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster294065 {
label="WholeStageCodegen (4)";
117350 [labelType="html" label="MapPartitionsRDD [117350] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster294027 {
label="AdaptiveSparkPlan";
117351 [labelType="html" label="MapPartitionsRDD [117351] [Unordered]<br>javaToPython at <unknown>:0"];
117352 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [facility_id#11984804, facility_uid#11984805, name#11984806, brand_context_id#11984807, owner_supplier_id#11984808, country#11984809, state#11984810, city#11984811, region#11984812, is_unknown#11984813, value_processes#11984814, materials#11984815, first_created_date#11985659]\n +- SortMergeJoin [facility_id#11984804], [facility_id#11981619], LeftOuter\n :- Sort [facility_id#11984804 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(facility_id#11984804, 10), ENSURE_REQUIREMENTS, [plan_id=3989222]\n : +- MapInPandas <lambda>(facility_id#11984779, facility_uid#11984780, name#11984781, brand_context_id#11984782, owner_supplier_id#11984783, country#11984784, state#11984785, city#11984786, region#11984787, is_unknown#11984788, value_processes#11984789, materials#11984790)#11984803, [facility_id#11984804, facility_uid#11984805, name#11984806, brand_context_id#11984807, owner_supplier_id#11984808, country#11984809, state#11984810, city#11... [117352] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster294311 {
label="InMemoryTableScan";
117437 [labelType="html" label="MapPartitionsRDD [117437] [Unordered]<br>javaToPython at <unknown>:0"];
117438 [labelType="html" label="MapPartitionsRDD [117438] [Unordered]<br>javaToPython at <unknown>:0"];
117439 [labelType="html" label="MapPartitionsRDD [117439] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster294300 {
label="WholeStageCodegen (2)";
117440 [labelType="html" label="MapPartitionsRDD [117440] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster294286 {
label="AdaptiveSparkPlan";
117441 [labelType="html" label="MapPartitionsRDD [117441] [Unordered]<br>javaToPython at <unknown>:0"];
117442 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [facility_id#11984804 AS entity_id#11994472, brand_context_id#11984807, dim_id#11994466, raw_level#11994467 AS level#11994473, CASE WHEN (cast(raw_level#11994467 as double) >= 4.2) THEN Extreme WHEN (cast(raw_level#11994467 as double) >= 3.4) THEN High WHEN (cast(raw_level#11994467 as double) >= 2.6) THEN Moderate WHEN (cast(raw_level#11994467 as double) >= 1.8) THEN Medium WHEN (cast(raw_level#11994467 as double) >= 1.0) THEN Low ELSE Unknown END AS level_band#11994474, active AS status#11994475, 2026-10-17T12:00:24.743559+00:00 AS listed_at#11994476, 2026-10-17T12:00:24.743559+00:00 AS assessed_at#11994477, null AS matched_entity#11994478, null AS match_pct#11994479, null AS match_source#11994480, null AS threshold#11994481, null AS kharon_id#11994482]\n +- Filter (isnotnull(raw_level#11994467) AND NOT (raw_level#11994467 = ))\n +- Generate stack(13, risk_child_labor, cast(Child_Labor#2019986 as string), risk_forced_labor, cast(Forced_Labor#2019985 as s... [117442] [Cached] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster294337 {
label="parallelize";
117456 [labelType="html" label="ParallelCollectionRDD [117456]<br>readRDDFromFile at PythonRDD.scala:289"];
}
subgraph cluster294338 {
label="mapPartitions";
117458 [labelType="html" label="MapPartitionsRDD [117458]<br>mapPartitions at SerDeUtil.scala:117"];
}
subgraph cluster294339 {
label="map";
117459 [labelType="html" label="MapPartitionsRDD [117459]<br>map at SerDeUtil.scala:69"];
}
subgraph cluster294340 {
label="mapPartitions";
117460 [labelType="html" label="MapPartitionsRDD [117460]<br>applySchemaToPythonRDD at <unknown>:0"];
}
subgraph cluster294371 {
label="InMemoryTableScan";
117466 [labelType="html" label="MapPartitionsRDD [117466] [Unordered]<br>javaToPython at <unknown>:0"];
117467 [labelType="html" label="MapPartitionsRDD [117467] [Unordered]<br>javaToPython at <unknown>:0"];
117468 [labelType="html" label="MapPartitionsRDD [117468] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster294366 {
label="WholeStageCodegen (2)";
117469 [labelType="html" label="MapPartitionsRDD [117469] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster294372 {
label="WholeStageCodegen (3)";
117470 [labelType="html" label="MapPartitionsRDD [117470]<br>javaToPython at <unknown>:0"];
}
subgraph cluster294365 {
label="Union";
117471 [labelType="html" label="UnionRDD [117471] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster294357 {
label="WholeStageCodegen (4)";
117472 [labelType="html" label="MapPartitionsRDD [117472] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster294342 {
label="AdaptiveSparkPlan";
117473 [labelType="html" label="MapPartitionsRDD [117473] [Unordered]<br>javaToPython at <unknown>:0"];
117474 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [facility_id#11996264, dim_id#11994466, lvl#11996265, sid#11996269]\n +- BroadcastHashJoin [facility_id#11996264], [facility_id#11983756], Inner, BuildRight, false\n :- Union\n : :- Project [entity_id#11994472 AS facility_id#11996264, dim_id#11994466, cast(level#11994473 as double) AS lvl#11996265]\n : : +- Filter ((isnotnull(dim_id#11994466) AND NOT (dim_id#11994466 = risk_overall)) AND isnotnull(entity_id#11994472))\n : : +- InMemoryTableScan [dim_id#11994466, entity_id#11994472, level#11994473], [isnotnull(dim_id#11994466), NOT (dim_id#11994466 = risk_overall), isnotnull(entity_id#11994472)]\n : : +- InMemoryRelation [entity_id#11994472, brand_context_id#11984807, dim_id#11994466, level#11994473, level_band#11994474, status#11994475, listed_at#11994476, assessed_at#11994477, matched_entity#11994478, match_pct#11994479, match_source#11994480, threshold#11994481, kharon_id#11994482], StorageLevel(disk, memory, deseriali... [117474] [Cached] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster294425 {
label="InMemoryTableScan";
117492 [labelType="html" label="MapPartitionsRDD [117492] [Unordered]<br>javaToPython at <unknown>:0"];
117493 [labelType="html" label="MapPartitionsRDD [117493] [Unordered]<br>javaToPython at <unknown>:0"];
117494 [labelType="html" label="MapPartitionsRDD [117494] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster294419 {
label="WholeStageCodegen (1)";
117495 [labelType="html" label="MapPartitionsRDD [117495] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster294418 {
label="Exchange";
117496 [labelType="html" label="MapPartitionsRDD [117496] [Unordered]<br>javaToPython at <unknown>:0"];
}
}
117253->117254;
117254->117255;
117255->117345;
117345->117346;
117346->117347;
117347->117348;
117348->117349;
117349->117350;
117350->117351;
117351->117352;
117352->117437;
117437->117438;
117438->117439;
117439->117440;
117440->117441;
117441->117442;
117456->117457;
117457->117458;
117458->117459;
117459->117460;
117442->117466;
117466->117467;
117467->117468;
117468->117469;
117460->117470;
117469->117471;
117470->117471;
117471->117472;
117472->117473;
117473->117474;
117474->117492;
117492->117493;
117493->117494;
117494->117495;
117495->117496;
}
117252,117253
117255
117442
117474