digraph G {
subgraph clusterstage_27769 {
label="Stage 27769";
121357 [labelType="html" label="JDBCRDD [121357]<br>cache at <unknown>:0"];
subgraph cluster303482 {
label="WholeStageCodegen (1)";
121358 [labelType="html" label="MapPartitionsRDD [121358]<br>count at <unknown>:0"];
}
subgraph cluster303484 {
label="mapPartitionsInternal";
121359 [labelType="html" label="MapPartitionsRDD [121359]<br>count at <unknown>:0"];
}
subgraph cluster303485 {
label="mapPartitionsInternal";
121360 [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#12310107,supplier_id#12310108,entity_name#12310109,city#12310110,state#12310111,country#12310112,supplier_type#12310113,declaring_supplier_id#12310114,canonical_id#12310115,is_primary#12310116,threshold#12310117,create_date#12310118] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [121360] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster303542 {
label="InMemoryTableScan";
121381 [labelType="html" label="MapPartitionsRDD [121381]<br>count at <unknown>:0"];
121382 [labelType="html" label="MapPartitionsRDD [121382]<br>count at <unknown>:0"];
121383 [labelType="html" label="MapPartitionsRDD [121383]<br>count at <unknown>:0"];
}
subgraph cluster303538 {
label="WholeStageCodegen (1)";
121384 [labelType="html" label="MapPartitionsRDD [121384]<br>count at <unknown>:0"];
}
subgraph cluster303543 {
label="mapPartitionsInternal";
121385 [labelType="html" label="MapPartitionsRDD [121385]<br>count at <unknown>:0"];
}
subgraph cluster303544 {
label="mapPartitionsInternal";
121386 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#12310115)\n +- InMemoryTableScan [brand_context_id#12310107, supplier_id#12310108, canonical_id#12310115, is_primary#12310116, entity_name#12310109, city#12310110, state#12310111, country#12310112, threshold#12310117, create_date#12310118], [isnotnull(canonical_id#12310115)]\n +- InMemoryRelation [brand_context_id#12310107, supplier_id#12310108, entity_name#12310109, city#12310110, state#12310111, country#12310112, supplier_type#12310113, declaring_supplier_id#12310114, canonical_id#12310115, is_primary#12310116, threshold#12310117, create_date#12310118], 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 ... [121386] [Cached]<br>count at <unknown>:0"];
}
}
121357->121358;
121358->121359;
121359->121360;
121360->121381;
121381->121382;
121382->121383;
121383->121384;
121384->121385;
121385->121386;
}
121360
121386