digraph G {
subgraph clusterstage_43749 {
label="Stage 43749";
190189 [labelType="html" label="JDBCRDD [190189]<br>cache at <unknown>:0"];
subgraph cluster448423 {
label="WholeStageCodegen (1)";
190190 [labelType="html" label="MapPartitionsRDD [190190]<br>count at <unknown>:0"];
}
subgraph cluster448425 {
label="mapPartitionsInternal";
190191 [labelType="html" label="MapPartitionsRDD [190191]<br>count at <unknown>:0"];
}
subgraph cluster448426 {
label="mapPartitionsInternal";
190192 [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#17255267,supplier_id#17255268,entity_name#17255269,city#17255270,state#17255271,country#17255272,supplier_type#17255273,declaring_supplier_id#17255274,canonical_id#17255275,is_primary#17255276,threshold#17255277,create_date#17255278] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [190192] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster448483 {
label="InMemoryTableScan";
190213 [labelType="html" label="MapPartitionsRDD [190213]<br>count at <unknown>:0"];
190214 [labelType="html" label="MapPartitionsRDD [190214]<br>count at <unknown>:0"];
190215 [labelType="html" label="MapPartitionsRDD [190215]<br>count at <unknown>:0"];
}
subgraph cluster448479 {
label="WholeStageCodegen (1)";
190216 [labelType="html" label="MapPartitionsRDD [190216]<br>count at <unknown>:0"];
}
subgraph cluster448484 {
label="mapPartitionsInternal";
190217 [labelType="html" label="MapPartitionsRDD [190217]<br>count at <unknown>:0"];
}
subgraph cluster448485 {
label="mapPartitionsInternal";
190218 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#17255275)\n +- InMemoryTableScan [brand_context_id#17255267, supplier_id#17255268, canonical_id#17255275, is_primary#17255276, entity_name#17255269, city#17255270, state#17255271, country#17255272, threshold#17255277, create_date#17255278], [isnotnull(canonical_id#17255275)]\n +- InMemoryRelation [brand_context_id#17255267, supplier_id#17255268, entity_name#17255269, city#17255270, state#17255271, country#17255272, supplier_type#17255273, declaring_supplier_id#17255274, canonical_id#17255275, is_primary#17255276, threshold#17255277, create_date#17255278], 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 ... [190218] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster448491 {
label="InMemoryTableScan";
190219 [labelType="html" label="MapPartitionsRDD [190219]<br>count at <unknown>:0"];
190220 [labelType="html" label="MapPartitionsRDD [190220]<br>count at <unknown>:0"];
190221 [labelType="html" label="MapPartitionsRDD [190221]<br>count at <unknown>:0"];
}
subgraph cluster448487 {
label="WholeStageCodegen (1)";
190222 [labelType="html" label="MapPartitionsRDD [190222]<br>count at <unknown>:0"];
}
subgraph cluster448486 {
label="Exchange";
190223 [labelType="html" label="MapPartitionsRDD [190223]<br>count at <unknown>:0"];
}
}
190189->190190;
190190->190191;
190191->190192;
190192->190213;
190213->190214;
190214->190215;
190215->190216;
190216->190217;
190217->190218;
190218->190219;
190219->190220;
190220->190221;
190221->190222;
190222->190223;
}
190192
190218