digraph G {
subgraph clusterstage_42721 {
label="Stage 42721";
186634 [labelType="html" label="JDBCRDD [186634]<br>cache at <unknown>:0"];
subgraph cluster440213 {
label="WholeStageCodegen (1)";
186635 [labelType="html" label="MapPartitionsRDD [186635]<br>count at <unknown>:0"];
}
subgraph cluster440215 {
label="mapPartitionsInternal";
186636 [labelType="html" label="MapPartitionsRDD [186636]<br>count at <unknown>:0"];
}
subgraph cluster440216 {
label="mapPartitionsInternal";
186637 [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#16976887,supplier_id#16976888,entity_name#16976889,city#16976890,state#16976891,country#16976892,supplier_type#16976893,declaring_supplier_id#16976894,canonical_id#16976895,is_primary#16976896,threshold#16976897,create_date#16976898] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [186637] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster440273 {
label="InMemoryTableScan";
186658 [labelType="html" label="MapPartitionsRDD [186658]<br>count at <unknown>:0"];
186659 [labelType="html" label="MapPartitionsRDD [186659]<br>count at <unknown>:0"];
186660 [labelType="html" label="MapPartitionsRDD [186660]<br>count at <unknown>:0"];
}
subgraph cluster440269 {
label="WholeStageCodegen (1)";
186661 [labelType="html" label="MapPartitionsRDD [186661]<br>count at <unknown>:0"];
}
subgraph cluster440274 {
label="mapPartitionsInternal";
186662 [labelType="html" label="MapPartitionsRDD [186662]<br>count at <unknown>:0"];
}
subgraph cluster440275 {
label="mapPartitionsInternal";
186663 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#16976895)\n +- InMemoryTableScan [brand_context_id#16976887, supplier_id#16976888, canonical_id#16976895, is_primary#16976896, entity_name#16976889, city#16976890, state#16976891, country#16976892, threshold#16976897, create_date#16976898], [isnotnull(canonical_id#16976895)]\n +- InMemoryRelation [brand_context_id#16976887, supplier_id#16976888, entity_name#16976889, city#16976890, state#16976891, country#16976892, supplier_type#16976893, declaring_supplier_id#16976894, canonical_id#16976895, is_primary#16976896, threshold#16976897, create_date#16976898], StorageLevel(disk, memory, deserialized, 1 replicas)\n +- *(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 ... [186663] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster440281 {
label="InMemoryTableScan";
186664 [labelType="html" label="MapPartitionsRDD [186664]<br>count at <unknown>:0"];
186665 [labelType="html" label="MapPartitionsRDD [186665]<br>count at <unknown>:0"];
186666 [labelType="html" label="MapPartitionsRDD [186666]<br>count at <unknown>:0"];
}
subgraph cluster440277 {
label="WholeStageCodegen (1)";
186667 [labelType="html" label="MapPartitionsRDD [186667]<br>count at <unknown>:0"];
}
subgraph cluster440276 {
label="Exchange";
186668 [labelType="html" label="MapPartitionsRDD [186668]<br>count at <unknown>:0"];
}
}
186634->186635;
186635->186636;
186636->186637;
186637->186658;
186658->186659;
186659->186660;
186660->186661;
186661->186662;
186662->186663;
186663->186664;
186664->186665;
186665->186666;
186666->186667;
186667->186668;
}
186637
186663