digraph G {
subgraph clusterstage_27703 {
label="Stage 27703";
121129 [labelType="html" label="JDBCRDD [121129]<br>cache at <unknown>:0"];
subgraph cluster302936 {
label="WholeStageCodegen (1)";
121130 [labelType="html" label="MapPartitionsRDD [121130]<br>count at <unknown>:0"];
}
subgraph cluster302938 {
label="mapPartitionsInternal";
121131 [labelType="html" label="MapPartitionsRDD [121131]<br>count at <unknown>:0"];
}
subgraph cluster302939 {
label="mapPartitionsInternal";
121132 [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#12301221,supplier_id#12301222,entity_name#12301223,city#12301224,state#12301225,country#12301226,supplier_type#12301227,declaring_supplier_id#12301228,canonical_id#12301229,is_primary#12301230,threshold#12301231,create_date#12301232] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [121132] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster302996 {
label="InMemoryTableScan";
121153 [labelType="html" label="MapPartitionsRDD [121153]<br>count at <unknown>:0"];
121154 [labelType="html" label="MapPartitionsRDD [121154]<br>count at <unknown>:0"];
121155 [labelType="html" label="MapPartitionsRDD [121155]<br>count at <unknown>:0"];
}
subgraph cluster302992 {
label="WholeStageCodegen (1)";
121156 [labelType="html" label="MapPartitionsRDD [121156]<br>count at <unknown>:0"];
}
subgraph cluster302997 {
label="mapPartitionsInternal";
121157 [labelType="html" label="MapPartitionsRDD [121157]<br>count at <unknown>:0"];
}
subgraph cluster302998 {
label="mapPartitionsInternal";
121158 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#12301229)\n +- InMemoryTableScan [brand_context_id#12301221, supplier_id#12301222, canonical_id#12301229, is_primary#12301230, entity_name#12301223, city#12301224, state#12301225, country#12301226, threshold#12301231, create_date#12301232], [isnotnull(canonical_id#12301229)]\n +- InMemoryRelation [brand_context_id#12301221, supplier_id#12301222, entity_name#12301223, city#12301224, state#12301225, country#12301226, supplier_type#12301227, declaring_supplier_id#12301228, canonical_id#12301229, is_primary#12301230, threshold#12301231, create_date#12301232], 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 ... [121158] [Cached]<br>count at <unknown>:0"];
}
}
121129->121130;
121130->121131;
121131->121132;
121132->121153;
121153->121154;
121154->121155;
121155->121156;
121156->121157;
121157->121158;
}
121132
121158