digraph G {
subgraph clusterstage_34049 {
label="Stage 34049";
149819 [labelType="html" label="SQLExecutionRDD [149819] [Unordered]<br>javaToPython at <unknown>:0"];
149822 [labelType="html" label="PythonRDD [149822] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
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] [Cached] [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 cluster361910 {
label="InMemoryTableScan";
149815 [labelType="html" label="MapPartitionsRDD [149815] [Unordered]<br>javaToPython at <unknown>:0"];
149816 [labelType="html" label="MapPartitionsRDD [149816] [Unordered]<br>javaToPython at <unknown>:0"];
149817 [labelType="html" label="MapPartitionsRDD [149817] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361908 {
label="Coalesce";
149818 [labelType="html" label="CoalescedRDD [149818] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361911 {
label="map";
149820 [labelType="html" label="MapPartitionsRDD [149820] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361912 {
label="mapPartitions";
149821 [labelType="html" label="MapPartitionsRDD [149821] [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;
149814->149815;
149815->149816;
149816->149817;
149817->149818;
149818->149819;
149819->149820;
149820->149821;
149821->149822;
}
149636,149637
149639
149726
149814