digraph G {
subgraph clusterstage_39678 {
label="Stage 39678";
169913 [labelType="html" label="PythonRDD [169913]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
169918 [labelType="html" label="PythonRDD [169918]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
subgraph cluster403976 {
label="Exchange";
169602 [labelType="html" label="ShuffledRowRDD [169602] [Unordered]<br>count at <unknown>:0"];
}
subgraph cluster403977 {
label="mapPartitionsInternal";
169603 [labelType="html" label="MapPartitionsRDD [169603] [Unordered]<br>count at <unknown>:0"];
}
subgraph cluster403978 {
label="mapPartitionsInternal";
169604 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Exchange SinglePartition, REPARTITION_BY_NUM, [plan_id=3316740]\n +- Project [brand_context_id#20322450, staticinvoke(class org.apache.spark.sql.catalyst.util.CharVarcharCodegenUtils, StringType, readSidePadding, NetworkID#20322451, 64, true, false, true) AS NetworkID#20322494, Child_Node#20322452, Parent_id#20322453, supplier_id#20322454, preferrd_supplier_id#20322455, supplier_ref_id#20322456, supplier_uid#20322457, supplier_name#20322458, supplier_country#20322459, direct_indirect#20322460, source_type#20322461, product_name#20322462, tier#20322463, is_latest#20322464, is_latest_submitted#20322465, is_unknown_supplier#20322466, company_id#20322467, config_name#20322468, direct_supplier_name#20322469, launch_request_name#20322470, launch_config_ref#20322471, revision_version#20322472, submission_status#20322473, ... 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... [169604] [Cached] [Unordered]<br>count at <unknown>:0"];
}
subgraph cluster404220 {
label="InMemoryTableScan";
169694 [labelType="html" label="MapPartitionsRDD [169694] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
169695 [labelType="html" label="MapPartitionsRDD [169695] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
169696 [labelType="html" label="MapPartitionsRDD [169696] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404211 {
label="WholeStageCodegen (3)";
169697 [labelType="html" label="MapPartitionsRDD [169697] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404210 {
label="MapInPandas";
169698 [labelType="html" label="MapPartitionsRDD [169698] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404202 {
label="WholeStageCodegen (4)";
169699 [labelType="html" label="MapPartitionsRDD [169699] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404106 {
label="AdaptiveSparkPlan";
169700 [labelType="html" label="MapPartitionsRDD [169700] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
169701 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [supplier_id#20328044, preferrd_supplier_id#20328045, supplier_uid#20328046, name#20328047, brand_context_id#20328048, country#20328049, state#20328050, city#20328051, region#20328052, status#20328053, is_unknown#20328054, source_evidence#20328055, first_created_date#20328359]\n +- SortMergeJoin [supplier_id#20328044], [supplier_id#20322205], LeftOuter\n :- Sort [supplier_id#20328044 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(supplier_id#20328044, 10), ENSURE_REQUIREMENTS, [plan_id=3316933]\n : +- MapInPandas <lambda>(supplier_id#20327871, preferrd_supplier_id#20327874, supplier_uid#20327875, name#20327876, brand_context_id#20327877, country#20327878, state#20327879, city#20327880, region#20327881, status#20327882, is_unknown#20327883, source_evidence#20327884)#20328043, [supplier_id#20328044, preferrd_supplier_id#20328045, supplier_uid#20328046, name#20328047, brand_context_id#20328048, country#20328049, state#20328050, city... [169701] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404305 {
label="InMemoryTableScan";
169734 [labelType="html" label="MapPartitionsRDD [169734] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
169735 [labelType="html" label="MapPartitionsRDD [169735] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
169736 [labelType="html" label="MapPartitionsRDD [169736] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404297 {
label="WholeStageCodegen (3)";
169737 [labelType="html" label="MapPartitionsRDD [169737] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404296 {
label="MapInPandas";
169738 [labelType="html" label="MapPartitionsRDD [169738] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404288 {
label="WholeStageCodegen (4)";
169739 [labelType="html" label="MapPartitionsRDD [169739] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404250 {
label="AdaptiveSparkPlan";
169740 [labelType="html" label="MapPartitionsRDD [169740] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
169741 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [facility_id#20328286, facility_uid#20328287, name#20328288, brand_context_id#20328289, owner_supplier_id#20328290, country#20328291, state#20328292, city#20328293, region#20328294, is_unknown#20328295, value_processes#20328296, materials#20328297, first_created_date#20329237]\n +- SortMergeJoin [facility_id#20328286], [facility_id#20322219], LeftOuter\n :- Sort [facility_id#20328286 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(facility_id#20328286, 10), ENSURE_REQUIREMENTS, [plan_id=3317012]\n : +- MapInPandas <lambda>(facility_id#20328187, facility_uid#20328188, name#20328189, brand_context_id#20328190, owner_supplier_id#20328191, country#20328192, state#20328193, city#20328194, region#20328195, is_unknown#20328196, value_processes#20328197, materials#20328211)#20328285, [facility_id#20328286, facility_uid#20328287, name#20328288, brand_context_id#20328289, owner_supplier_id#20328290, country#20328291, state#20328292, city#20... [169741] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404460 {
label="InMemoryTableScan";
169791 [labelType="html" label="MapPartitionsRDD [169791] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
169792 [labelType="html" label="MapPartitionsRDD [169792] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
169793 [labelType="html" label="MapPartitionsRDD [169793] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404448 {
label="WholeStageCodegen (4)";
169794 [labelType="html" label="MapPartitionsRDD [169794] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404447 {
label="MapInPandas";
169795 [labelType="html" label="MapPartitionsRDD [169795] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404439 {
label="WholeStageCodegen (5)";
169796 [labelType="html" label="MapPartitionsRDD [169796] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404398 {
label="AdaptiveSparkPlan";
169797 [labelType="html" label="MapPartitionsRDD [169797] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
169798 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [supplier_id#20332245, supplier_uid#20332246, name#20332247, brand_context_id#20332248, country#20332249, state#20332250, city#20332251, region#20332252, status#20332253, is_unknown#20332254, source_evidence#20332255, first_created_date#20332274]\n +- SortMergeJoin [supplier_id#20332245], [supplier_id#20332277], LeftOuter\n :- Sort [supplier_id#20332245 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(supplier_id#20332245, 10), ENSURE_REQUIREMENTS, [plan_id=3317188]\n : +- MapInPandas <lambda>(supplier_id#20332071, supplier_uid#20332072, name#20332073, brand_context_id#20332074, country#20332076, state#20332077, city#20332078, region#20332079, status#20332124, is_unknown#20332133, source_evidence#20332134)#20332244, [supplier_id#20332245, supplier_uid#20332246, name#20332247, brand_context_id#20332248, country#20332249, state#20332250, city#20332251, region#20332252, status#20332253, is_unknown#20332254, source_evidence#20332255], ... [169798] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404639 {
label="InMemoryTableScan";
169865 [labelType="html" label="MapPartitionsRDD [169865] [Unordered]<br>javaToPython at <unknown>:0"];
169866 [labelType="html" label="MapPartitionsRDD [169866] [Unordered]<br>javaToPython at <unknown>:0"];
169867 [labelType="html" label="MapPartitionsRDD [169867] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster404635 {
label="WholeStageCodegen (2)";
169868 [labelType="html" label="MapPartitionsRDD [169868] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster404644 {
label="InMemoryTableScan";
169869 [labelType="html" label="MapPartitionsRDD [169869] [Unordered]<br>javaToPython at <unknown>:0"];
169870 [labelType="html" label="MapPartitionsRDD [169870] [Unordered]<br>javaToPython at <unknown>:0"];
169871 [labelType="html" label="MapPartitionsRDD [169871] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster404640 {
label="WholeStageCodegen (3)";
169872 [labelType="html" label="MapPartitionsRDD [169872] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster404634 {
label="Union";
169873 [labelType="html" label="UnionRDD [169873] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster404625 {
label="WholeStageCodegen (4)";
169874 [labelType="html" label="MapPartitionsRDD [169874] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster404611 {
label="AdaptiveSparkPlan";
169875 [labelType="html" label="MapPartitionsRDD [169875] [Unordered]<br>javaToPython at <unknown>:0"];
169876 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [supplier_id#20328044 AS entity_id#20343505, brand_context_id#20328048, dim_id#20343499, raw_level#20343500 AS level#20343506, CASE WHEN (cast(raw_level#20343500 as double) >= 4.2) THEN Extreme WHEN (cast(raw_level#20343500 as double) >= 3.4) THEN High WHEN (cast(raw_level#20343500 as double) >= 2.6) THEN Moderate WHEN (cast(raw_level#20343500 as double) >= 1.8) THEN Medium WHEN (cast(raw_level#20343500 as double) >= 1.0) THEN Low ELSE Unknown END AS level_band#20343507, active AS status#20343508, 2026-10-16T12:48:36.100823+00:00 AS listed_at#20343509, 2026-10-16T12:48:36.100823+00:00 AS assessed_at#20343510, null AS matched_entity#20343511, null AS match_pct#20343512, null AS match_source#20343513, null AS threshold#20343514, null AS kharon_id#20343515]\n +- Filter (isnotnull(raw_level#20343500) AND NOT (raw_level#20343500 = ))\n +- Generate stack(13, risk_child_labor, cast(Child_Labor#11541293 as string), risk_forced_labor, cast(Forced_Labor#11541292 as... [169876] [Cached] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster404712 {
label="InMemoryTableScan";
169898 [labelType="html" label="MapPartitionsRDD [169898] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
169899 [labelType="html" label="MapPartitionsRDD [169899] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
169900 [labelType="html" label="MapPartitionsRDD [169900] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404701 {
label="WholeStageCodegen (2)";
169901 [labelType="html" label="MapPartitionsRDD [169901] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404687 {
label="AdaptiveSparkPlan";
169902 [labelType="html" label="MapPartitionsRDD [169902] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
169903 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [facility_id#20328286 AS entity_id#20344365, brand_context_id#20328289, dim_id#20344359, raw_level#20344360 AS level#20344366, CASE WHEN (cast(raw_level#20344360 as double) >= 4.2) THEN Extreme WHEN (cast(raw_level#20344360 as double) >= 3.4) THEN High WHEN (cast(raw_level#20344360 as double) >= 2.6) THEN Moderate WHEN (cast(raw_level#20344360 as double) >= 1.8) THEN Medium WHEN (cast(raw_level#20344360 as double) >= 1.0) THEN Low ELSE Unknown END AS level_band#20344367, active AS status#20344368, 2026-10-16T12:48:36.100823+00:00 AS listed_at#20344369, 2026-10-16T12:48:36.100823+00:00 AS assessed_at#20344370, null AS matched_entity#20344371, null AS match_pct#20344372, null AS match_source#20344373, null AS threshold#20344374, null AS kharon_id#20344375]\n +- Filter (isnotnull(raw_level#20344360) AND NOT (raw_level#20344360 = ))\n +- Generate stack(13, risk_child_labor, cast(Child_Labor#11541293 as string), risk_forced_labor, cast(Forced_Labor#11541292 as... [169903] [Cached] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404752 {
label="parallelize";
169912 [labelType="html" label="ParallelCollectionRDD [169912]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404753 {
label="mapPartitions";
169914 [labelType="html" label="MapPartitionsRDD [169914]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404754 {
label="map";
169915 [labelType="html" label="MapPartitionsRDD [169915]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404755 {
label="mapPartitions";
169916 [labelType="html" label="MapPartitionsRDD [169916]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404756 {
label="parallelize";
169917 [labelType="html" label="ParallelCollectionRDD [169917]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404757 {
label="mapPartitions";
169919 [labelType="html" label="MapPartitionsRDD [169919]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404758 {
label="map";
169920 [labelType="html" label="MapPartitionsRDD [169920]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404759 {
label="mapPartitions";
169921 [labelType="html" label="MapPartitionsRDD [169921]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404874 {
label="InMemoryTableScan";
169957 [labelType="html" label="MapPartitionsRDD [169957] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
169958 [labelType="html" label="MapPartitionsRDD [169958] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
169959 [labelType="html" label="MapPartitionsRDD [169959] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404863 {
label="WholeStageCodegen (2)";
169960 [labelType="html" label="MapPartitionsRDD [169960] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404875 {
label="WholeStageCodegen (3)";
169961 [labelType="html" label="MapPartitionsRDD [169961]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404862 {
label="Union";
169962 [labelType="html" label="UnionRDD [169962] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404854 {
label="WholeStageCodegen (4)";
169963 [labelType="html" label="MapPartitionsRDD [169963] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404801 {
label="AdaptiveSparkPlan";
169964 [labelType="html" label="MapPartitionsRDD [169964] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
169965 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [facility_id#20346240, dim_id#20344359, lvl#20346241, sid#20346246]\n +- BroadcastHashJoin [facility_id#20346240], [facility_id#20326208], Inner, BuildRight, false\n :- Union\n : :- Project [entity_id#20344365 AS facility_id#20346240, dim_id#20344359, cast(level#20344366 as double) AS lvl#20346241]\n : : +- Filter ((isnotnull(dim_id#20344359) AND NOT (dim_id#20344359 = risk_overall)) AND isnotnull(entity_id#20344365))\n : : +- InMemoryTableScan [dim_id#20344359, entity_id#20344365, level#20344366], [isnotnull(dim_id#20344359), NOT (dim_id#20344359 = risk_overall), isnotnull(entity_id#20344365)]\n : : +- InMemoryRelation [entity_id#20344365, brand_context_id#20328289, dim_id#20344359, level#20344366, level_band#20344367, status#20344368, listed_at#20344369, assessed_at#20344370, matched_entity#20344371, match_pct#20344372, match_source#20344373, threshold#20344374, kharon_id#20344375], StorageLevel(disk, memory, deseriali... [169965] [Cached] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
169984 [labelType="html" label="MapPartitionsRDD [169984] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
169985 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [sid#20346616, dim_id#20343499, lvl#20346630, _has_fac#20347372]\n +- BroadcastHashJoin [sid#20346616], [sid#20347155], LeftOuter, BuildRight, false\n :- Union\n : :- Project [entity_id#20343505 AS sid#20346616, dim_id#20343499, cast(level#20343506 as double) AS lvl#20346630]\n : : +- Filter (isnotnull(dim_id#20343499) AND NOT (dim_id#20343499 = risk_overall))\n : : +- InMemoryTableScan [dim_id#20343499, entity_id#20343505, level#20343506], [isnotnull(dim_id#20343499), NOT (dim_id#20343499 = risk_overall)]\n : : +- InMemoryRelation [entity_id#20343505, brand_context_id#20328048, dim_id#20343499, level#20343506, level_band#20343507, status#20343508, listed_at#20343509, assessed_at#20343510, matched_entity#20343511, match_pct#20343512, match_source#20343513, threshold#20343514, kharon_id#20343515], StorageLevel(disk, memory, deserialized, 1 replicas)\n : : +- AdaptiveSparkPlan isFinalPlan=false\n :... [169985] [Cached] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404921 {
label="InMemoryTableScan";
169977 [labelType="html" label="MapPartitionsRDD [169977] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
169978 [labelType="html" label="MapPartitionsRDD [169978] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
169979 [labelType="html" label="MapPartitionsRDD [169979] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404916 {
label="WholeStageCodegen (2)";
169980 [labelType="html" label="MapPartitionsRDD [169980] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404922 {
label="WholeStageCodegen (3)";
169981 [labelType="html" label="MapPartitionsRDD [169981]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404915 {
label="Union";
169982 [labelType="html" label="UnionRDD [169982] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404907 {
label="WholeStageCodegen (4)";
169983 [labelType="html" label="MapPartitionsRDD [169983] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404938 {
label="InMemoryTableScan";
169994 [labelType="html" label="MapPartitionsRDD [169994] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
169995 [labelType="html" label="MapPartitionsRDD [169995] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
169996 [labelType="html" label="MapPartitionsRDD [169996] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404944 {
label="InMemoryTableScan";
169997 [labelType="html" label="MapPartitionsRDD [169997] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
169998 [labelType="html" label="MapPartitionsRDD [169998] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
169999 [labelType="html" label="MapPartitionsRDD [169999] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404939 {
label="WholeStageCodegen (1)";
170000 [labelType="html" label="MapPartitionsRDD [170000] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404950 {
label="InMemoryTableScan";
170001 [labelType="html" label="MapPartitionsRDD [170001] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
170002 [labelType="html" label="MapPartitionsRDD [170002] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
170003 [labelType="html" label="MapPartitionsRDD [170003] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404945 {
label="WholeStageCodegen (2)";
170004 [labelType="html" label="MapPartitionsRDD [170004] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404936 {
label="Union";
170005 [labelType="html" label="UnionRDD [170005] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404933 {
label="WholeStageCodegen (3)";
170006 [labelType="html" label="MapPartitionsRDD [170006] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
subgraph cluster404932 {
label="Exchange";
170007 [labelType="html" label="MapPartitionsRDD [170007] [Unordered]<br>foreachPartition at /opt/app/scheduler/jobs/memgraph_loader_job.py:2107"];
}
}
169602->169603;
169603->169604;
169604->169694;
169694->169695;
169695->169696;
169696->169697;
169697->169698;
169698->169699;
169699->169700;
169700->169701;
169604->169734;
169734->169735;
169735->169736;
169736->169737;
169737->169738;
169738->169739;
169739->169740;
169740->169741;
169604->169791;
169791->169792;
169792->169793;
169793->169794;
169794->169795;
169795->169796;
169796->169797;
169797->169798;
169701->169865;
169865->169866;
169866->169867;
169867->169868;
169798->169869;
169869->169870;
169870->169871;
169871->169872;
169868->169873;
169872->169873;
169873->169874;
169874->169875;
169875->169876;
169741->169898;
169898->169899;
169899->169900;
169900->169901;
169901->169902;
169902->169903;
169912->169913;
169913->169914;
169914->169915;
169915->169916;
169917->169918;
169918->169919;
169919->169920;
169920->169921;
169903->169957;
169957->169958;
169958->169959;
169959->169960;
169921->169961;
169960->169962;
169961->169962;
169962->169963;
169963->169964;
169964->169965;
169876->169977;
169977->169978;
169978->169979;
169979->169980;
169916->169981;
169980->169982;
169981->169982;
169982->169983;
169983->169984;
169984->169985;
169965->169994;
169994->169995;
169995->169996;
169985->169997;
169997->169998;
169998->169999;
169999->170000;
169985->170001;
170001->170002;
170002->170003;
170003->170004;
169996->170005;
170000->170005;
170004->170005;
170005->170006;
170006->170007;
}
169599,169602
169604
169876
169903
169965
169985