digraph G {
subgraph clusterstage_3330 {
label="Stage 3330";
11826 [labelType="html" label="JDBCRDD [11826]<br>cache at <unknown>:0"];
subgraph cluster26959 {
label="WholeStageCodegen (1)";
11827 [labelType="html" label="MapPartitionsRDD [11827]<br>count at <unknown>:0"];
}
subgraph cluster26961 {
label="mapPartitionsInternal";
11828 [labelType="html" label="MapPartitionsRDD [11828]<br>count at <unknown>:0"];
}
subgraph cluster26962 {
label="mapPartitionsInternal";
11829 [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#1063127,supplier_id#1063128,entity_name#1063129,city#1063130,state#1063131,country#1063132,supplier_type#1063133,declaring_supplier_id#1063134,canonical_id#1063135,is_primary#1063136,threshold#1063137,create_date#1063138] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [11829] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster27019 {
label="InMemoryTableScan";
11850 [labelType="html" label="MapPartitionsRDD [11850]<br>count at <unknown>:0"];
11851 [labelType="html" label="MapPartitionsRDD [11851]<br>count at <unknown>:0"];
11852 [labelType="html" label="MapPartitionsRDD [11852]<br>count at <unknown>:0"];
}
subgraph cluster27015 {
label="WholeStageCodegen (1)";
11853 [labelType="html" label="MapPartitionsRDD [11853]<br>count at <unknown>:0"];
}
subgraph cluster27020 {
label="mapPartitionsInternal";
11854 [labelType="html" label="MapPartitionsRDD [11854]<br>count at <unknown>:0"];
}
subgraph cluster27021 {
label="mapPartitionsInternal";
11855 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#1063135)\n +- InMemoryTableScan [brand_context_id#1063127, supplier_id#1063128, canonical_id#1063135, is_primary#1063136, entity_name#1063129, city#1063130, state#1063131, country#1063132, threshold#1063137, create_date#1063138], [isnotnull(canonical_id#1063135)]\n +- InMemoryRelation [brand_context_id#1063127, supplier_id#1063128, entity_name#1063129, city#1063130, state#1063131, country#1063132, supplier_type#1063133, declaring_supplier_id#1063134, canonical_id#1063135, is_primary#1063136, threshold#1063137, create_date#1063138], 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 v.canonical_id,\n ... [11855] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster27027 {
label="InMemoryTableScan";
11856 [labelType="html" label="MapPartitionsRDD [11856]<br>count at <unknown>:0"];
11857 [labelType="html" label="MapPartitionsRDD [11857]<br>count at <unknown>:0"];
11858 [labelType="html" label="MapPartitionsRDD [11858]<br>count at <unknown>:0"];
}
subgraph cluster27023 {
label="WholeStageCodegen (1)";
11859 [labelType="html" label="MapPartitionsRDD [11859]<br>count at <unknown>:0"];
}
subgraph cluster27022 {
label="Exchange";
11860 [labelType="html" label="MapPartitionsRDD [11860]<br>count at <unknown>:0"];
}
}
11826->11827;
11827->11828;
11828->11829;
11829->11850;
11850->11851;
11851->11852;
11852->11853;
11853->11854;
11854->11855;
11855->11856;
11856->11857;
11857->11858;
11858->11859;
11859->11860;
}
11829
11855