digraph G {
subgraph clusterstage_44156 {
label="Stage 44156";
191557 [labelType="html" label="JDBCRDD [191557]<br>cache at <unknown>:0"];
subgraph cluster451699 {
label="WholeStageCodegen (1)";
191558 [labelType="html" label="MapPartitionsRDD [191558]<br>count at <unknown>:0"];
}
subgraph cluster451701 {
label="mapPartitionsInternal";
191559 [labelType="html" label="MapPartitionsRDD [191559]<br>count at <unknown>:0"];
}
subgraph cluster451702 {
label="mapPartitionsInternal";
191560 [labelType="html" label="*(1) Scan JDBCRelation((\n SELECT DISTINCT\n v.brand_context_id,\n v.supplier_id,\n v.entity_name,\n v.city,\n v.state,\n v.country,\n v.supplier_type,\n v.declaring_supplier_id,\n v.canonical_id,\n v.is_primary,\n COALESCE(v.threshold, 0.9) AS threshold,\n v.create_date\n FROM vw_all_suppliers_for_dedup v\n ) AS all_suppliers) [numPartitions=1] [brand_context_id#17308583,supplier_id#17308584,entity_name#17308585,city#17308586,state#17308587,country#17308588,supplier_type#17308589,declaring_supplier_id#17308590,canonical_id#17308591,is_primary#17308592,threshold#17308593,create_date#17308594] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [191560] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster451734 {
label="InMemoryTableScan";
191569 [labelType="html" label="MapPartitionsRDD [191569]<br>count at <unknown>:0"];
191570 [labelType="html" label="MapPartitionsRDD [191570]<br>count at <unknown>:0"];
191571 [labelType="html" label="MapPartitionsRDD [191571]<br>count at <unknown>:0"];
}
subgraph cluster451729 {
label="WholeStageCodegen (1)";
191572 [labelType="html" label="MapPartitionsRDD [191572]<br>count at <unknown>:0"];
}
subgraph cluster451735 {
label="mapPartitionsInternal";
191573 [labelType="html" label="MapPartitionsRDD [191573]<br>count at <unknown>:0"];
}
subgraph cluster451736 {
label="mapPartitionsInternal";
191574 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#17308583, supplier_id#17308584, entity_name#17308585, city#17308586, state#17308587, country#17308588, supplier_type#17308589, declaring_supplier_id#17308590, threshold#17308593, create_date#17308594]\n +- Filter isnull(canonical_id#17308591)\n +- InMemoryTableScan [brand_context_id#17308583, canonical_id#17308591, city#17308586, country#17308588, create_date#17308594, declaring_supplier_id#17308590, entity_name#17308585, state#17308587, supplier_id#17308584, supplier_type#17308589, threshold#17308593], [isnull(canonical_id#17308591)]\n +- InMemoryRelation [brand_context_id#17308583, supplier_id#17308584, entity_name#17308585, city#17308586, state#17308587, country#17308588, supplier_type#17308589, declaring_supplier_id#17308590, canonical_id#17308591, is_primary#17308592, threshold#17308593, create_date#17308594], StorageLevel(disk, memory, deserialized, 1 replicas)\n +- *(1) Scan JDBCRelation((\n SEL... [191574] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster451862 {
label="InMemoryTableScan";
191625 [labelType="html" label="MapPartitionsRDD [191625]<br>count at <unknown>:0"];
191626 [labelType="html" label="MapPartitionsRDD [191626]<br>count at <unknown>:0"];
191627 [labelType="html" label="MapPartitionsRDD [191627]<br>count at <unknown>:0"];
}
subgraph cluster451854 {
label="WholeStageCodegen (2)";
191628 [labelType="html" label="MapPartitionsRDD [191628]<br>count at <unknown>:0"];
}
subgraph cluster451853 {
label="BatchEvalPython";
191629 [labelType="html" label="MapPartitionsRDD [191629]<br>count at <unknown>:0"];
191630 [labelType="html" label="MapPartitionsRDD [191630]<br>count at <unknown>:0"];
}
subgraph cluster451845 {
label="WholeStageCodegen (3)";
191631 [labelType="html" label="MapPartitionsRDD [191631]<br>count at <unknown>:0"];
}
subgraph cluster451844 {
label="BatchEvalPython";
191632 [labelType="html" label="MapPartitionsRDD [191632]<br>count at <unknown>:0"];
191633 [labelType="html" label="MapPartitionsRDD [191633]<br>count at <unknown>:0"];
}
subgraph cluster451838 {
label="WholeStageCodegen (4)";
191634 [labelType="html" label="MapPartitionsRDD [191634]<br>count at <unknown>:0"];
}
subgraph cluster451837 {
label="Exchange";
191635 [labelType="html" label="MapPartitionsRDD [191635]<br>count at <unknown>:0"];
}
}
191557->191558;
191558->191559;
191559->191560;
191560->191569;
191569->191570;
191570->191571;
191571->191572;
191572->191573;
191573->191574;
191574->191625;
191625->191626;
191626->191627;
191627->191628;
191628->191629;
191629->191630;
191630->191631;
191631->191632;
191632->191633;
191633->191634;
191634->191635;
}
191560
191574