digraph G {
subgraph clusterstage_26738 {
label="Stage 26738";
117813 [labelType="html" label="SQLExecutionRDD [117813] [Unordered]<br>javaToPython at <unknown>:0"];
117816 [labelType="html" label="PythonRDD [117816] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
subgraph cluster294752 {
label="Exchange";
117625 [labelType="html" label="ShuffledRowRDD [117625] [Unordered]<br>count at <unknown>:0"];
}
subgraph cluster294753 {
label="mapPartitionsInternal";
117626 [labelType="html" label="MapPartitionsRDD [117626] [Unordered]<br>count at <unknown>:0"];
}
subgraph cluster294754 {
label="mapPartitionsInternal";
117627 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Exchange SinglePartition, REPARTITION_BY_NUM, [plan_id=3993705]\n +- Project [brand_context_id#12010729, staticinvoke(class org.apache.spark.sql.catalyst.util.CharVarcharCodegenUtils, StringType, readSidePadding, NetworkID#12010730, 64, true, false, true) AS NetworkID#12010773, Child_Node#12010731, Parent_id#12010732, supplier_id#12010733, preferrd_supplier_id#12010734, supplier_ref_id#12010735, supplier_uid#12010736, supplier_name#12010737, supplier_country#12010738, direct_indirect#12010739, source_type#12010740, product_name#12010741, tier#12010742, is_latest#12010743, is_latest_submitted#12010744, is_unknown_supplier#12010745, company_id#12010746, config_name#12010747, direct_supplier_name#12010748, launch_request_name#12010749, launch_config_ref#12010750, revision_version#12010751, submission_status#12010752, ... 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... [117627] [Cached] [Unordered]<br>count at <unknown>:0"];
}
subgraph cluster294984 {
label="InMemoryTableScan";
117711 [labelType="html" label="MapPartitionsRDD [117711] [Unordered]<br>javaToPython at <unknown>:0"];
117712 [labelType="html" label="MapPartitionsRDD [117712] [Unordered]<br>javaToPython at <unknown>:0"];
117713 [labelType="html" label="MapPartitionsRDD [117713] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster294976 {
label="WholeStageCodegen (3)";
117714 [labelType="html" label="MapPartitionsRDD [117714] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster294975 {
label="MapInPandas";
117715 [labelType="html" label="MapPartitionsRDD [117715] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster294967 {
label="WholeStageCodegen (4)";
117716 [labelType="html" label="MapPartitionsRDD [117716] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster294929 {
label="AdaptiveSparkPlan";
117717 [labelType="html" label="MapPartitionsRDD [117717] [Unordered]<br>javaToPython at <unknown>:0"];
117718 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [facility_id#12013683, facility_uid#12013684, name#12013685, brand_context_id#12013686, owner_supplier_id#12013687, country#12013688, state#12013689, city#12013690, region#12013691, is_unknown#12013692, value_processes#12013693, materials#12013694, first_created_date#12014538]\n +- SortMergeJoin [facility_id#12013683], [facility_id#12010498], LeftOuter\n :- Sort [facility_id#12013683 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(facility_id#12013683, 10), ENSURE_REQUIREMENTS, [plan_id=3993882]\n : +- MapInPandas <lambda>(facility_id#12013658, facility_uid#12013659, name#12013660, brand_context_id#12013661, owner_supplier_id#12013662, country#12013663, state#12013664, city#12013665, region#12013666, is_unknown#12013667, value_processes#12013668, materials#12013669)#12013682, [facility_id#12013683, facility_uid#12013684, name#12013685, brand_context_id#12013686, owner_supplier_id#12013687, country#12013688, state#12013689, city#12... [117718] [Cached] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster295213 {
label="InMemoryTableScan";
117803 [labelType="html" label="MapPartitionsRDD [117803] [Unordered]<br>javaToPython at <unknown>:0"];
117804 [labelType="html" label="MapPartitionsRDD [117804] [Unordered]<br>javaToPython at <unknown>:0"];
117805 [labelType="html" label="MapPartitionsRDD [117805] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster295202 {
label="WholeStageCodegen (2)";
117806 [labelType="html" label="MapPartitionsRDD [117806] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster295188 {
label="AdaptiveSparkPlan";
117807 [labelType="html" label="MapPartitionsRDD [117807] [Unordered]<br>javaToPython at <unknown>:0"];
117808 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [facility_id#12013683 AS entity_id#12023116, brand_context_id#12013686, dim_id#12023110, raw_level#12023111 AS level#12023117, CASE WHEN (cast(raw_level#12023111 as double) >= 4.2) THEN Extreme WHEN (cast(raw_level#12023111 as double) >= 3.4) THEN High WHEN (cast(raw_level#12023111 as double) >= 2.6) THEN Moderate WHEN (cast(raw_level#12023111 as double) >= 1.8) THEN Medium WHEN (cast(raw_level#12023111 as double) >= 1.0) THEN Low ELSE Unknown END AS level_band#12023118, active AS status#12023119, 2026-10-17T12:00:51.962854+00:00 AS listed_at#12023120, 2026-10-17T12:00:51.962854+00:00 AS assessed_at#12023121, null AS matched_entity#12023122, null AS match_pct#12023123, null AS match_source#12023124, null AS threshold#12023125, null AS kharon_id#12023126]\n +- Filter (isnotnull(raw_level#12023111) AND NOT (raw_level#12023111 = ))\n +- Generate stack(13, risk_child_labor, cast(Child_Labor#2019986 as string), risk_forced_labor, cast(Forced_Labor#2019985 as s... [117808] [Cached] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster295216 {
label="InMemoryTableScan";
117809 [labelType="html" label="MapPartitionsRDD [117809] [Unordered]<br>javaToPython at <unknown>:0"];
117810 [labelType="html" label="MapPartitionsRDD [117810] [Unordered]<br>javaToPython at <unknown>:0"];
117811 [labelType="html" label="MapPartitionsRDD [117811] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster295214 {
label="Coalesce";
117812 [labelType="html" label="CoalescedRDD [117812] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster295217 {
label="map";
117814 [labelType="html" label="MapPartitionsRDD [117814] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster295218 {
label="mapPartitions";
117815 [labelType="html" label="MapPartitionsRDD [117815] [Unordered]<br>javaToPython at <unknown>:0"];
}
}
117625->117626;
117626->117627;
117627->117711;
117711->117712;
117712->117713;
117713->117714;
117714->117715;
117715->117716;
117716->117717;
117717->117718;
117718->117803;
117803->117804;
117804->117805;
117805->117806;
117806->117807;
117807->117808;
117808->117809;
117809->117810;
117810->117811;
117811->117812;
117812->117813;
117813->117814;
117814->117815;
117815->117816;
}
117624,117625
117627
117718
117808