digraph G {
subgraph clusterstage_30152 {
label="Stage 30152";
129711 [labelType="html" label="JDBCRDD [129711]<br>cache at <unknown>:0"];
subgraph cluster322727 {
label="WholeStageCodegen (1)";
129712 [labelType="html" label="MapPartitionsRDD [129712]<br>count at <unknown>:0"];
}
subgraph cluster322729 {
label="mapPartitionsInternal";
129713 [labelType="html" label="MapPartitionsRDD [129713]<br>count at <unknown>:0"];
}
subgraph cluster322730 {
label="mapPartitionsInternal";
129714 [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#12972378,supplier_id#12972379,entity_name#12972380,city#12972381,state#12972382,country#12972383,supplier_type#12972384,declaring_supplier_id#12972385,canonical_id#12972386,is_primary#12972387,threshold#12972388,create_date#12972389] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [129714] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster322762 {
label="InMemoryTableScan";
129723 [labelType="html" label="MapPartitionsRDD [129723]<br>count at <unknown>:0"];
129724 [labelType="html" label="MapPartitionsRDD [129724]<br>count at <unknown>:0"];
129725 [labelType="html" label="MapPartitionsRDD [129725]<br>count at <unknown>:0"];
}
subgraph cluster322757 {
label="WholeStageCodegen (1)";
129726 [labelType="html" label="MapPartitionsRDD [129726]<br>count at <unknown>:0"];
}
subgraph cluster322763 {
label="mapPartitionsInternal";
129727 [labelType="html" label="MapPartitionsRDD [129727]<br>count at <unknown>:0"];
}
subgraph cluster322764 {
label="mapPartitionsInternal";
129728 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#12972378, supplier_id#12972379, entity_name#12972380, city#12972381, state#12972382, country#12972383, supplier_type#12972384, declaring_supplier_id#12972385, threshold#12972388, create_date#12972389]\n +- Filter isnull(canonical_id#12972386)\n +- InMemoryTableScan [brand_context_id#12972378, canonical_id#12972386, city#12972381, country#12972383, create_date#12972389, declaring_supplier_id#12972385, entity_name#12972380, state#12972382, supplier_id#12972379, supplier_type#12972384, threshold#12972388], [isnull(canonical_id#12972386)]\n +- InMemoryRelation [brand_context_id#12972378, supplier_id#12972379, entity_name#12972380, city#12972381, state#12972382, country#12972383, supplier_type#12972384, declaring_supplier_id#12972385, canonical_id#12972386, is_primary#12972387, threshold#12972388, create_date#12972389], StorageLevel(disk, memory, deserialized, 1 replicas)\n +- *(1) Scan JDBCRelation((\n SEL... [129728] [Cached]<br>count at <unknown>:0"];
}
}
129711->129712;
129712->129713;
129713->129714;
129714->129723;
129723->129724;
129724->129725;
129725->129726;
129726->129727;
129727->129728;
}
129714
129728