digraph G {
subgraph clusterstage_28677 {
label="Stage 28677";
124494 [labelType="html" label="JDBCRDD [124494]<br>cache at <unknown>:0"];
subgraph cluster310691 {
label="WholeStageCodegen (1)";
124495 [labelType="html" label="MapPartitionsRDD [124495]<br>count at <unknown>:0"];
}
subgraph cluster310693 {
label="mapPartitionsInternal";
124496 [labelType="html" label="MapPartitionsRDD [124496]<br>count at <unknown>:0"];
}
subgraph cluster310694 {
label="mapPartitionsInternal";
124497 [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#12572196,supplier_id#12572197,entity_name#12572198,city#12572199,state#12572200,country#12572201,supplier_type#12572202,declaring_supplier_id#12572203,canonical_id#12572204,is_primary#12572205,threshold#12572206,create_date#12572207] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [124497] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster310751 {
label="InMemoryTableScan";
124518 [labelType="html" label="MapPartitionsRDD [124518]<br>count at <unknown>:0"];
124519 [labelType="html" label="MapPartitionsRDD [124519]<br>count at <unknown>:0"];
124520 [labelType="html" label="MapPartitionsRDD [124520]<br>count at <unknown>:0"];
}
subgraph cluster310747 {
label="WholeStageCodegen (1)";
124521 [labelType="html" label="MapPartitionsRDD [124521]<br>count at <unknown>:0"];
}
subgraph cluster310752 {
label="mapPartitionsInternal";
124522 [labelType="html" label="MapPartitionsRDD [124522]<br>count at <unknown>:0"];
}
subgraph cluster310753 {
label="mapPartitionsInternal";
124523 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#12572204)\n +- InMemoryTableScan [brand_context_id#12572196, supplier_id#12572197, canonical_id#12572204, is_primary#12572205, entity_name#12572198, city#12572199, state#12572200, country#12572201, threshold#12572206, create_date#12572207], [isnotnull(canonical_id#12572204)]\n +- InMemoryRelation [brand_context_id#12572196, supplier_id#12572197, entity_name#12572198, city#12572199, state#12572200, country#12572201, supplier_type#12572202, declaring_supplier_id#12572203, canonical_id#12572204, is_primary#12572205, threshold#12572206, create_date#12572207], 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 ... [124523] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster310759 {
label="InMemoryTableScan";
124524 [labelType="html" label="MapPartitionsRDD [124524]<br>count at <unknown>:0"];
124525 [labelType="html" label="MapPartitionsRDD [124525]<br>count at <unknown>:0"];
124526 [labelType="html" label="MapPartitionsRDD [124526]<br>count at <unknown>:0"];
}
subgraph cluster310755 {
label="WholeStageCodegen (1)";
124527 [labelType="html" label="MapPartitionsRDD [124527]<br>count at <unknown>:0"];
}
subgraph cluster310754 {
label="Exchange";
124528 [labelType="html" label="MapPartitionsRDD [124528]<br>count at <unknown>:0"];
}
}
124494->124495;
124495->124496;
124496->124497;
124497->124518;
124518->124519;
124519->124520;
124520->124521;
124521->124522;
124522->124523;
124523->124524;
124524->124525;
124525->124526;
124526->124527;
124527->124528;
}
124497
124523