digraph G {
subgraph clusterstage_26859 {
label="Stage 26859";
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 cluster296308 {
label="InMemoryTableScan";
118232 [labelType="html" label="MapPartitionsRDD [118232]<br>count at <unknown>:0"];
118233 [labelType="html" label="MapPartitionsRDD [118233]<br>count at <unknown>:0"];
118234 [labelType="html" label="MapPartitionsRDD [118234]<br>count at <unknown>:0"];
}
subgraph cluster296303 {
label="WholeStageCodegen (1)";
118235 [labelType="html" label="MapPartitionsRDD [118235]<br>count at <unknown>:0"];
}
subgraph cluster296309 {
label="mapPartitionsInternal";
118236 [labelType="html" label="MapPartitionsRDD [118236]<br>count at <unknown>:0"];
}
subgraph cluster296310 {
label="mapPartitionsInternal";
118237 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#12048018, supplier_id#12048019, entity_name#12048020, city#12048021, state#12048022, country#12048023, supplier_type#12048024, declaring_supplier_id#12048025, threshold#12048028, create_date#12048029]\n +- Filter isnull(canonical_id#12048026)\n +- InMemoryTableScan [brand_context_id#12048018, canonical_id#12048026, city#12048021, country#12048023, create_date#12048029, declaring_supplier_id#12048025, entity_name#12048020, state#12048022, supplier_id#12048019, supplier_type#12048024, threshold#12048028], [isnull(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 SEL... [118237] [Cached]<br>count at <unknown>:0"];
}
}
118220->118221;
118221->118222;
118222->118223;
118223->118232;
118232->118233;
118233->118234;
118234->118235;
118235->118236;
118236->118237;
}
118223
118237