digraph G {
subgraph clusterstage_26862 {
label="Stage 26862";
118220 [labelType="html" label="JDBCRDD [118220]<br>cache at <unknown>:0"];
subgraph cluster296273 {
label="WholeStageCodegen (1)";
118221 [labelType="html" label="MapPartitionsRDD [118221]<br>count at <unknown>:0"];
}
subgraph cluster296275 {
label="mapPartitionsInternal";
118222 [labelType="html" label="MapPartitionsRDD [118222]<br>count at <unknown>:0"];
}
subgraph cluster296276 {
label="mapPartitionsInternal";
118223 [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#12048018,supplier_id#12048019,entity_name#12048020,city#12048021,state#12048022,country#12048023,supplier_type#12048024,declaring_supplier_id#12048025,canonical_id#12048026,is_primary#12048027,threshold#12048028,create_date#12048029] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [118223] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster296333 {
label="InMemoryTableScan";
118244 [labelType="html" label="MapPartitionsRDD [118244]<br>count at <unknown>:0"];
118245 [labelType="html" label="MapPartitionsRDD [118245]<br>count at <unknown>:0"];
118246 [labelType="html" label="MapPartitionsRDD [118246]<br>count at <unknown>:0"];
}
subgraph cluster296329 {
label="WholeStageCodegen (1)";
118247 [labelType="html" label="MapPartitionsRDD [118247]<br>count at <unknown>:0"];
}
subgraph cluster296334 {
label="mapPartitionsInternal";
118248 [labelType="html" label="MapPartitionsRDD [118248]<br>count at <unknown>:0"];
}
subgraph cluster296335 {
label="mapPartitionsInternal";
118249 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#12048026)\n +- InMemoryTableScan [brand_context_id#12048018, supplier_id#12048019, canonical_id#12048026, is_primary#12048027, entity_name#12048020, city#12048021, state#12048022, country#12048023, threshold#12048028, create_date#12048029], [isnotnull(canonical_id#12048026)]\n +- InMemoryRelation [brand_context_id#12048018, supplier_id#12048019, entity_name#12048020, city#12048021, state#12048022, country#12048023, supplier_type#12048024, declaring_supplier_id#12048025, canonical_id#12048026, is_primary#12048027, threshold#12048028, create_date#12048029], 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 ... [118249] [Cached]<br>count at <unknown>:0"];
}
}
118220->118221;
118221->118222;
118222->118223;
118223->118244;
118244->118245;
118245->118246;
118246->118247;
118247->118248;
118248->118249;
}
118223
118249