digraph G {
subgraph clusterstage_26885 {
label="Stage 26885";
118296 [labelType="html" label="JDBCRDD [118296]<br>cache at <unknown>:0"];
subgraph cluster296455 {
label="WholeStageCodegen (1)";
118297 [labelType="html" label="MapPartitionsRDD [118297]<br>count at <unknown>:0"];
}
subgraph cluster296457 {
label="mapPartitionsInternal";
118298 [labelType="html" label="MapPartitionsRDD [118298]<br>count at <unknown>:0"];
}
subgraph cluster296458 {
label="mapPartitionsInternal";
118299 [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#12050980,supplier_id#12050981,entity_name#12050982,city#12050983,state#12050984,country#12050985,supplier_type#12050986,declaring_supplier_id#12050987,canonical_id#12050988,is_primary#12050989,threshold#12050990,create_date#12050991] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [118299] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster296515 {
label="InMemoryTableScan";
118320 [labelType="html" label="MapPartitionsRDD [118320]<br>count at <unknown>:0"];
118321 [labelType="html" label="MapPartitionsRDD [118321]<br>count at <unknown>:0"];
118322 [labelType="html" label="MapPartitionsRDD [118322]<br>count at <unknown>:0"];
}
subgraph cluster296511 {
label="WholeStageCodegen (1)";
118323 [labelType="html" label="MapPartitionsRDD [118323]<br>count at <unknown>:0"];
}
subgraph cluster296516 {
label="mapPartitionsInternal";
118324 [labelType="html" label="MapPartitionsRDD [118324]<br>count at <unknown>:0"];
}
subgraph cluster296517 {
label="mapPartitionsInternal";
118325 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#12050988)\n +- InMemoryTableScan [brand_context_id#12050980, supplier_id#12050981, canonical_id#12050988, is_primary#12050989, entity_name#12050982, city#12050983, state#12050984, country#12050985, threshold#12050990, create_date#12050991], [isnotnull(canonical_id#12050988)]\n +- InMemoryRelation [brand_context_id#12050980, supplier_id#12050981, entity_name#12050982, city#12050983, state#12050984, country#12050985, supplier_type#12050986, declaring_supplier_id#12050987, canonical_id#12050988, is_primary#12050989, threshold#12050990, create_date#12050991], 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 ... [118325] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster296523 {
label="InMemoryTableScan";
118326 [labelType="html" label="MapPartitionsRDD [118326]<br>count at <unknown>:0"];
118327 [labelType="html" label="MapPartitionsRDD [118327]<br>count at <unknown>:0"];
118328 [labelType="html" label="MapPartitionsRDD [118328]<br>count at <unknown>:0"];
}
subgraph cluster296519 {
label="WholeStageCodegen (1)";
118329 [labelType="html" label="MapPartitionsRDD [118329]<br>count at <unknown>:0"];
}
subgraph cluster296518 {
label="Exchange";
118330 [labelType="html" label="MapPartitionsRDD [118330]<br>count at <unknown>:0"];
}
}
118296->118297;
118297->118298;
118298->118299;
118299->118320;
118320->118321;
118321->118322;
118322->118323;
118323->118324;
118324->118325;
118325->118326;
118326->118327;
118327->118328;
118328->118329;
118329->118330;
}
118299
118325