digraph G {
subgraph clusterstage_27737 {
label="Stage 27737";
121243 [labelType="html" label="JDBCRDD [121243]<br>cache at <unknown>:0"];
subgraph cluster303209 {
label="WholeStageCodegen (1)";
121244 [labelType="html" label="MapPartitionsRDD [121244]<br>count at <unknown>:0"];
}
subgraph cluster303211 {
label="mapPartitionsInternal";
121245 [labelType="html" label="MapPartitionsRDD [121245]<br>count at <unknown>:0"];
}
subgraph cluster303212 {
label="mapPartitionsInternal";
121246 [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#12305664,supplier_id#12305665,entity_name#12305666,city#12305667,state#12305668,country#12305669,supplier_type#12305670,declaring_supplier_id#12305671,canonical_id#12305672,is_primary#12305673,threshold#12305674,create_date#12305675] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [121246] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster303269 {
label="InMemoryTableScan";
121267 [labelType="html" label="MapPartitionsRDD [121267]<br>count at <unknown>:0"];
121268 [labelType="html" label="MapPartitionsRDD [121268]<br>count at <unknown>:0"];
121269 [labelType="html" label="MapPartitionsRDD [121269]<br>count at <unknown>:0"];
}
subgraph cluster303265 {
label="WholeStageCodegen (1)";
121270 [labelType="html" label="MapPartitionsRDD [121270]<br>count at <unknown>:0"];
}
subgraph cluster303270 {
label="mapPartitionsInternal";
121271 [labelType="html" label="MapPartitionsRDD [121271]<br>count at <unknown>:0"];
}
subgraph cluster303271 {
label="mapPartitionsInternal";
121272 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#12305672)\n +- InMemoryTableScan [brand_context_id#12305664, supplier_id#12305665, canonical_id#12305672, is_primary#12305673, entity_name#12305666, city#12305667, state#12305668, country#12305669, threshold#12305674, create_date#12305675], [isnotnull(canonical_id#12305672)]\n +- InMemoryRelation [brand_context_id#12305664, supplier_id#12305665, entity_name#12305666, city#12305667, state#12305668, country#12305669, supplier_type#12305670, declaring_supplier_id#12305671, canonical_id#12305672, is_primary#12305673, threshold#12305674, create_date#12305675], 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 ... [121272] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster303277 {
label="InMemoryTableScan";
121273 [labelType="html" label="MapPartitionsRDD [121273]<br>count at <unknown>:0"];
121274 [labelType="html" label="MapPartitionsRDD [121274]<br>count at <unknown>:0"];
121275 [labelType="html" label="MapPartitionsRDD [121275]<br>count at <unknown>:0"];
}
subgraph cluster303273 {
label="WholeStageCodegen (1)";
121276 [labelType="html" label="MapPartitionsRDD [121276]<br>count at <unknown>:0"];
}
subgraph cluster303272 {
label="Exchange";
121277 [labelType="html" label="MapPartitionsRDD [121277]<br>count at <unknown>:0"];
}
}
121243->121244;
121244->121245;
121245->121246;
121246->121267;
121267->121268;
121268->121269;
121269->121270;
121270->121271;
121271->121272;
121272->121273;
121273->121274;
121274->121275;
121275->121276;
121276->121277;
}
121246
121272