digraph G {
subgraph clusterstage_44090 {
label="Stage 44090";
191367 [labelType="html" label="JDBCRDD [191367]<br>cache at <unknown>:0"];
subgraph cluster451244 {
label="WholeStageCodegen (1)";
191368 [labelType="html" label="MapPartitionsRDD [191368]<br>count at <unknown>:0"];
}
subgraph cluster451246 {
label="mapPartitionsInternal";
191369 [labelType="html" label="MapPartitionsRDD [191369]<br>count at <unknown>:0"];
}
subgraph cluster451247 {
label="mapPartitionsInternal";
191370 [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#17301178,supplier_id#17301179,entity_name#17301180,city#17301181,state#17301182,country#17301183,supplier_type#17301184,declaring_supplier_id#17301185,canonical_id#17301186,is_primary#17301187,threshold#17301188,create_date#17301189] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [191370] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster451304 {
label="InMemoryTableScan";
191391 [labelType="html" label="MapPartitionsRDD [191391]<br>count at <unknown>:0"];
191392 [labelType="html" label="MapPartitionsRDD [191392]<br>count at <unknown>:0"];
191393 [labelType="html" label="MapPartitionsRDD [191393]<br>count at <unknown>:0"];
}
subgraph cluster451300 {
label="WholeStageCodegen (1)";
191394 [labelType="html" label="MapPartitionsRDD [191394]<br>count at <unknown>:0"];
}
subgraph cluster451305 {
label="mapPartitionsInternal";
191395 [labelType="html" label="MapPartitionsRDD [191395]<br>count at <unknown>:0"];
}
subgraph cluster451306 {
label="mapPartitionsInternal";
191396 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#17301186)\n +- InMemoryTableScan [brand_context_id#17301178, supplier_id#17301179, canonical_id#17301186, is_primary#17301187, entity_name#17301180, city#17301181, state#17301182, country#17301183, threshold#17301188, create_date#17301189], [isnotnull(canonical_id#17301186)]\n +- InMemoryRelation [brand_context_id#17301178, supplier_id#17301179, entity_name#17301180, city#17301181, state#17301182, country#17301183, supplier_type#17301184, declaring_supplier_id#17301185, canonical_id#17301186, is_primary#17301187, threshold#17301188, create_date#17301189], 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 ... [191396] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster451312 {
label="InMemoryTableScan";
191397 [labelType="html" label="MapPartitionsRDD [191397]<br>count at <unknown>:0"];
191398 [labelType="html" label="MapPartitionsRDD [191398]<br>count at <unknown>:0"];
191399 [labelType="html" label="MapPartitionsRDD [191399]<br>count at <unknown>:0"];
}
subgraph cluster451308 {
label="WholeStageCodegen (1)";
191400 [labelType="html" label="MapPartitionsRDD [191400]<br>count at <unknown>:0"];
}
subgraph cluster451307 {
label="Exchange";
191401 [labelType="html" label="MapPartitionsRDD [191401]<br>count at <unknown>:0"];
}
}
191367->191368;
191368->191369;
191369->191370;
191370->191391;
191391->191392;
191392->191393;
191393->191394;
191394->191395;
191395->191396;
191396->191397;
191397->191398;
191398->191399;
191399->191400;
191400->191401;
}
191370
191396