digraph G {
subgraph clusterstage_30876 {
label="Stage 30876";
132202 [labelType="html" label="JDBCRDD [132202]<br>cache at <unknown>:0"];
subgraph cluster328389 {
label="WholeStageCodegen (1)";
132203 [labelType="html" label="MapPartitionsRDD [132203]<br>count at <unknown>:0"];
}
subgraph cluster328391 {
label="mapPartitionsInternal";
132204 [labelType="html" label="MapPartitionsRDD [132204]<br>count at <unknown>:0"];
}
subgraph cluster328392 {
label="mapPartitionsInternal";
132205 [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#13209290,supplier_id#13209291,entity_name#13209292,city#13209293,state#13209294,country#13209295,supplier_type#13209296,declaring_supplier_id#13209297,canonical_id#13209298,is_primary#13209299,threshold#13209300,create_date#13209301] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [132205] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster328449 {
label="InMemoryTableScan";
132226 [labelType="html" label="MapPartitionsRDD [132226]<br>count at <unknown>:0"];
132227 [labelType="html" label="MapPartitionsRDD [132227]<br>count at <unknown>:0"];
132228 [labelType="html" label="MapPartitionsRDD [132228]<br>count at <unknown>:0"];
}
subgraph cluster328445 {
label="WholeStageCodegen (1)";
132229 [labelType="html" label="MapPartitionsRDD [132229]<br>count at <unknown>:0"];
}
subgraph cluster328450 {
label="mapPartitionsInternal";
132230 [labelType="html" label="MapPartitionsRDD [132230]<br>count at <unknown>:0"];
}
subgraph cluster328451 {
label="mapPartitionsInternal";
132231 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#13209298)\n +- InMemoryTableScan [brand_context_id#13209290, supplier_id#13209291, canonical_id#13209298, is_primary#13209299, entity_name#13209292, city#13209293, state#13209294, country#13209295, threshold#13209300, create_date#13209301], [isnotnull(canonical_id#13209298)]\n +- InMemoryRelation [brand_context_id#13209290, supplier_id#13209291, entity_name#13209292, city#13209293, state#13209294, country#13209295, supplier_type#13209296, declaring_supplier_id#13209297, canonical_id#13209298, is_primary#13209299, threshold#13209300, create_date#13209301], 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 ... [132231] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster328457 {
label="InMemoryTableScan";
132232 [labelType="html" label="MapPartitionsRDD [132232]<br>count at <unknown>:0"];
132233 [labelType="html" label="MapPartitionsRDD [132233]<br>count at <unknown>:0"];
132234 [labelType="html" label="MapPartitionsRDD [132234]<br>count at <unknown>:0"];
}
subgraph cluster328453 {
label="WholeStageCodegen (1)";
132235 [labelType="html" label="MapPartitionsRDD [132235]<br>count at <unknown>:0"];
}
subgraph cluster328452 {
label="Exchange";
132236 [labelType="html" label="MapPartitionsRDD [132236]<br>count at <unknown>:0"];
}
}
132202->132203;
132203->132204;
132204->132205;
132205->132226;
132226->132227;
132227->132228;
132228->132229;
132229->132230;
132230->132231;
132231->132232;
132232->132233;
132233->132234;
132234->132235;
132235->132236;
}
132205
132231