digraph G {
subgraph clusterstage_27755 {
label="Stage 27755";
121319 [labelType="html" label="JDBCRDD [121319]<br>cache at <unknown>:0"];
subgraph cluster303391 {
label="WholeStageCodegen (1)";
121320 [labelType="html" label="MapPartitionsRDD [121320]<br>count at <unknown>:0"];
}
subgraph cluster303393 {
label="mapPartitionsInternal";
121321 [labelType="html" label="MapPartitionsRDD [121321]<br>count at <unknown>:0"];
}
subgraph cluster303394 {
label="mapPartitionsInternal";
121322 [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#12308626,supplier_id#12308627,entity_name#12308628,city#12308629,state#12308630,country#12308631,supplier_type#12308632,declaring_supplier_id#12308633,canonical_id#12308634,is_primary#12308635,threshold#12308636,create_date#12308637] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [121322] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster303426 {
label="InMemoryTableScan";
121331 [labelType="html" label="MapPartitionsRDD [121331]<br>count at <unknown>:0"];
121332 [labelType="html" label="MapPartitionsRDD [121332]<br>count at <unknown>:0"];
121333 [labelType="html" label="MapPartitionsRDD [121333]<br>count at <unknown>:0"];
}
subgraph cluster303421 {
label="WholeStageCodegen (1)";
121334 [labelType="html" label="MapPartitionsRDD [121334]<br>count at <unknown>:0"];
}
subgraph cluster303427 {
label="mapPartitionsInternal";
121335 [labelType="html" label="MapPartitionsRDD [121335]<br>count at <unknown>:0"];
}
subgraph cluster303428 {
label="mapPartitionsInternal";
121336 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#12308626, supplier_id#12308627, entity_name#12308628, city#12308629, state#12308630, country#12308631, supplier_type#12308632, declaring_supplier_id#12308633, threshold#12308636, create_date#12308637]\n +- Filter isnull(canonical_id#12308634)\n +- InMemoryTableScan [brand_context_id#12308626, canonical_id#12308634, city#12308629, country#12308631, create_date#12308637, declaring_supplier_id#12308633, entity_name#12308628, state#12308630, supplier_id#12308627, supplier_type#12308632, threshold#12308636], [isnull(canonical_id#12308634)]\n +- InMemoryRelation [brand_context_id#12308626, supplier_id#12308627, entity_name#12308628, city#12308629, state#12308630, country#12308631, supplier_type#12308632, declaring_supplier_id#12308633, canonical_id#12308634, is_primary#12308635, threshold#12308636, create_date#12308637], StorageLevel(disk, memory, deserialized, 1 replicas)\n +- *(1) Scan JDBCRelation((\n SEL... [121336] [Cached]<br>count at <unknown>:0"];
}
}
121319->121320;
121320->121321;
121321->121322;
121322->121331;
121331->121332;
121332->121333;
121333->121334;
121334->121335;
121335->121336;
}
121322
121336