digraph G {
subgraph clusterstage_34035 {
label="Stage 34035";
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 cluster361633 {
label="InMemoryTableScan";
149689 [labelType="html" label="MapPartitionsRDD [149689] [Unordered]<br>javaToPython at <unknown>:0"];
149690 [labelType="html" label="MapPartitionsRDD [149690] [Unordered]<br>javaToPython at <unknown>:0"];
149691 [labelType="html" label="MapPartitionsRDD [149691] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361624 {
label="WholeStageCodegen (3)";
149692 [labelType="html" label="MapPartitionsRDD [149692] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361623 {
label="MapInPandas";
149693 [labelType="html" label="MapPartitionsRDD [149693] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361615 {
label="WholeStageCodegen (4)";
149694 [labelType="html" label="MapPartitionsRDD [149694] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361577 {
label="AdaptiveSparkPlan";
149695 [labelType="html" label="MapPartitionsRDD [149695] [Unordered]<br>javaToPython at <unknown>:0"];
149696 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [supplier_id#14302869, preferrd_supplier_id#14302870, supplier_uid#14302871, name#14302872, brand_context_id#14302873, country#14302874, state#14302875, city#14302876, region#14302877, status#14302878, is_unknown#14302879, source_evidence#14302880, first_created_date#14303038]\n +- SortMergeJoin [supplier_id#14302869], [supplier_id#14299815], LeftOuter\n :- Sort [supplier_id#14302869 ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(supplier_id#14302869, 10), ENSURE_REQUIREMENTS, [plan_id=4247900]\n : +- MapInPandas <lambda>(supplier_id#14302844, preferrd_supplier_id#14302845, supplier_uid#14302846, name#14302847, brand_context_id#14302848, country#14302849, state#14302850, city#14302851, region#14302852, status#14302853, is_unknown#14302854, source_evidence#14302855)#14302868, [supplier_id#14302869, preferrd_supplier_id#14302870, supplier_uid#14302871, name#14302872, brand_context_id#14302873, country#14302874, state#14302875, city... [149696] [Cached] [Unordered]<br>javaToPython at <unknown>:0"];
}
subgraph cluster361745 {
label="InMemoryTableScan";
149739 [labelType="html" label="MapPartitionsRDD [149739] [Unordered]<br>$anonfun$withThreadLocalCaptured$1 at <unknown>:0"];
149741 [labelType="html" label="MapPartitionsRDD [149741] [Unordered]<br>$anonfun$withThreadLocalCaptured$1 at <unknown>:0"];
149743 [labelType="html" label="MapPartitionsRDD [149743] [Unordered]<br>$anonfun$withThreadLocalCaptured$1 at <unknown>:0"];
}
subgraph cluster361732 {
label="WholeStageCodegen (2)";
149746 [labelType="html" label="MapPartitionsRDD [149746] [Unordered]<br>$anonfun$withThreadLocalCaptured$1 at <unknown>:0"];
}
subgraph cluster361726 {
label="BroadcastExchange";
149749 [labelType="html" label="MapPartitionsRDD [149749] [Unordered]<br>$anonfun$withThreadLocalCaptured$1 at <unknown>:0"];
}
}
149637->149638;
149638->149639;
149639->149689;
149689->149690;
149690->149691;
149691->149692;
149692->149693;
149693->149694;
149694->149695;
149695->149696;
149696->149739;
149739->149741;
149741->149743;
149743->149746;
149746->149749;
}
149636,149637
149639
149696