digraph G {
subgraph clusterstage_43745 {
label="Stage 43745";
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 cluster448458 {
label="InMemoryTableScan";
190201 [labelType="html" label="MapPartitionsRDD [190201]<br>count at <unknown>:0"];
190202 [labelType="html" label="MapPartitionsRDD [190202]<br>count at <unknown>:0"];
190203 [labelType="html" label="MapPartitionsRDD [190203]<br>count at <unknown>:0"];
}
subgraph cluster448453 {
label="WholeStageCodegen (1)";
190204 [labelType="html" label="MapPartitionsRDD [190204]<br>count at <unknown>:0"];
}
subgraph cluster448459 {
label="mapPartitionsInternal";
190205 [labelType="html" label="MapPartitionsRDD [190205]<br>count at <unknown>:0"];
}
subgraph cluster448460 {
label="mapPartitionsInternal";
190206 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#17255267, supplier_id#17255268, entity_name#17255269, city#17255270, state#17255271, country#17255272, supplier_type#17255273, declaring_supplier_id#17255274, threshold#17255277, create_date#17255278]\n +- Filter isnull(canonical_id#17255275)\n +- InMemoryTableScan [brand_context_id#17255267, canonical_id#17255275, city#17255270, country#17255272, create_date#17255278, declaring_supplier_id#17255274, entity_name#17255269, state#17255271, supplier_id#17255268, supplier_type#17255273, threshold#17255277], [isnull(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 SEL... [190206] [Cached]<br>count at <unknown>:0"];
}
}
190189->190190;
190190->190191;
190191->190192;
190192->190201;
190201->190202;
190202->190203;
190203->190204;
190204->190205;
190205->190206;
}
190192
190206