digraph G {
subgraph clusterstage_2598 {
label="Stage 2598";
9297 [labelType="html" label="JDBCRDD [9297]<br>cache at <unknown>:0"];
subgraph cluster21206 {
label="WholeStageCodegen (1)";
9298 [labelType="html" label="MapPartitionsRDD [9298]<br>count at <unknown>:0"];
}
subgraph cluster21208 {
label="mapPartitionsInternal";
9299 [labelType="html" label="MapPartitionsRDD [9299]<br>count at <unknown>:0"];
}
subgraph cluster21209 {
label="mapPartitionsInternal";
9300 [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#824734,supplier_id#824735,entity_name#824736,city#824737,state#824738,country#824739,supplier_type#824740,declaring_supplier_id#824741,canonical_id#824742,is_primary#824743,threshold#824744,create_date#824745] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [9300] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster21266 {
label="InMemoryTableScan";
9321 [labelType="html" label="MapPartitionsRDD [9321]<br>count at <unknown>:0"];
9322 [labelType="html" label="MapPartitionsRDD [9322]<br>count at <unknown>:0"];
9323 [labelType="html" label="MapPartitionsRDD [9323]<br>count at <unknown>:0"];
}
subgraph cluster21262 {
label="WholeStageCodegen (1)";
9324 [labelType="html" label="MapPartitionsRDD [9324]<br>count at <unknown>:0"];
}
subgraph cluster21267 {
label="mapPartitionsInternal";
9325 [labelType="html" label="MapPartitionsRDD [9325]<br>count at <unknown>:0"];
}
subgraph cluster21268 {
label="mapPartitionsInternal";
9326 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#824742)\n +- InMemoryTableScan [brand_context_id#824734, supplier_id#824735, canonical_id#824742, is_primary#824743, entity_name#824736, city#824737, state#824738, country#824739, threshold#824744, create_date#824745], [isnotnull(canonical_id#824742)]\n +- InMemoryRelation [brand_context_id#824734, supplier_id#824735, entity_name#824736, city#824737, state#824738, country#824739, supplier_type#824740, declaring_supplier_id#824741, canonical_id#824742, is_primary#824743, threshold#824744, create_date#824745], 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 v.canonical_id,\n v.is_prima... [9326] [Cached]<br>count at <unknown>:0"];
}
}
9297->9298;
9298->9299;
9299->9300;
9300->9321;
9321->9322;
9322->9323;
9323->9324;
9324->9325;
9325->9326;
}
9300
9326