digraph G {
subgraph clusterstage_43969 {
label="Stage 43969";
190949 [labelType="html" label="JDBCRDD [190949]<br>cache at <unknown>:0"];
subgraph cluster450243 {
label="WholeStageCodegen (1)";
190950 [labelType="html" label="MapPartitionsRDD [190950]<br>count at <unknown>:0"];
}
subgraph cluster450245 {
label="mapPartitionsInternal";
190951 [labelType="html" label="MapPartitionsRDD [190951]<br>count at <unknown>:0"];
}
subgraph cluster450246 {
label="mapPartitionsInternal";
190952 [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#17284887,supplier_id#17284888,entity_name#17284889,city#17284890,state#17284891,country#17284892,supplier_type#17284893,declaring_supplier_id#17284894,canonical_id#17284895,is_primary#17284896,threshold#17284897,create_date#17284898] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [190952] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster450303 {
label="InMemoryTableScan";
190973 [labelType="html" label="MapPartitionsRDD [190973]<br>count at <unknown>:0"];
190974 [labelType="html" label="MapPartitionsRDD [190974]<br>count at <unknown>:0"];
190975 [labelType="html" label="MapPartitionsRDD [190975]<br>count at <unknown>:0"];
}
subgraph cluster450299 {
label="WholeStageCodegen (1)";
190976 [labelType="html" label="MapPartitionsRDD [190976]<br>count at <unknown>:0"];
}
subgraph cluster450304 {
label="mapPartitionsInternal";
190977 [labelType="html" label="MapPartitionsRDD [190977]<br>count at <unknown>:0"];
}
subgraph cluster450305 {
label="mapPartitionsInternal";
190978 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#17284895)\n +- InMemoryTableScan [brand_context_id#17284887, supplier_id#17284888, canonical_id#17284895, is_primary#17284896, entity_name#17284889, city#17284890, state#17284891, country#17284892, threshold#17284897, create_date#17284898], [isnotnull(canonical_id#17284895)]\n +- InMemoryRelation [brand_context_id#17284887, supplier_id#17284888, entity_name#17284889, city#17284890, state#17284891, country#17284892, supplier_type#17284893, declaring_supplier_id#17284894, canonical_id#17284895, is_primary#17284896, threshold#17284897, create_date#17284898], 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 ... [190978] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster450311 {
label="InMemoryTableScan";
190979 [labelType="html" label="MapPartitionsRDD [190979]<br>count at <unknown>:0"];
190980 [labelType="html" label="MapPartitionsRDD [190980]<br>count at <unknown>:0"];
190981 [labelType="html" label="MapPartitionsRDD [190981]<br>count at <unknown>:0"];
}
subgraph cluster450307 {
label="WholeStageCodegen (1)";
190982 [labelType="html" label="MapPartitionsRDD [190982]<br>count at <unknown>:0"];
}
subgraph cluster450306 {
label="Exchange";
190983 [labelType="html" label="MapPartitionsRDD [190983]<br>count at <unknown>:0"];
}
}
190949->190950;
190950->190951;
190951->190952;
190952->190973;
190973->190974;
190974->190975;
190975->190976;
190976->190977;
190977->190978;
190978->190979;
190979->190980;
190980->190981;
190981->190982;
190982->190983;
}
190952
190978