digraph G {
subgraph clusterstage_42001 {
label="Stage 42001";
184143 [labelType="html" label="JDBCRDD [184143]<br>cache at <unknown>:0"];
subgraph cluster434551 {
label="WholeStageCodegen (1)";
184144 [labelType="html" label="MapPartitionsRDD [184144]<br>count at <unknown>:0"];
}
subgraph cluster434553 {
label="mapPartitionsInternal";
184145 [labelType="html" label="MapPartitionsRDD [184145]<br>count at <unknown>:0"];
}
subgraph cluster434554 {
label="mapPartitionsInternal";
184146 [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#16739975,supplier_id#16739976,entity_name#16739977,city#16739978,state#16739979,country#16739980,supplier_type#16739981,declaring_supplier_id#16739982,canonical_id#16739983,is_primary#16739984,threshold#16739985,create_date#16739986] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [184146] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster434611 {
label="InMemoryTableScan";
184167 [labelType="html" label="MapPartitionsRDD [184167]<br>count at <unknown>:0"];
184168 [labelType="html" label="MapPartitionsRDD [184168]<br>count at <unknown>:0"];
184169 [labelType="html" label="MapPartitionsRDD [184169]<br>count at <unknown>:0"];
}
subgraph cluster434607 {
label="WholeStageCodegen (1)";
184170 [labelType="html" label="MapPartitionsRDD [184170]<br>count at <unknown>:0"];
}
subgraph cluster434612 {
label="mapPartitionsInternal";
184171 [labelType="html" label="MapPartitionsRDD [184171]<br>count at <unknown>:0"];
}
subgraph cluster434613 {
label="mapPartitionsInternal";
184172 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#16739983)\n +- InMemoryTableScan [brand_context_id#16739975, supplier_id#16739976, canonical_id#16739983, is_primary#16739984, entity_name#16739977, city#16739978, state#16739979, country#16739980, threshold#16739985, create_date#16739986], [isnotnull(canonical_id#16739983)]\n +- InMemoryRelation [brand_context_id#16739975, supplier_id#16739976, entity_name#16739977, city#16739978, state#16739979, country#16739980, supplier_type#16739981, declaring_supplier_id#16739982, canonical_id#16739983, is_primary#16739984, threshold#16739985, create_date#16739986], 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 ... [184172] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster434619 {
label="InMemoryTableScan";
184173 [labelType="html" label="MapPartitionsRDD [184173]<br>count at <unknown>:0"];
184174 [labelType="html" label="MapPartitionsRDD [184174]<br>count at <unknown>:0"];
184175 [labelType="html" label="MapPartitionsRDD [184175]<br>count at <unknown>:0"];
}
subgraph cluster434615 {
label="WholeStageCodegen (1)";
184176 [labelType="html" label="MapPartitionsRDD [184176]<br>count at <unknown>:0"];
}
subgraph cluster434614 {
label="Exchange";
184177 [labelType="html" label="MapPartitionsRDD [184177]<br>count at <unknown>:0"];
}
}
184143->184144;
184144->184145;
184145->184146;
184146->184167;
184167->184168;
184168->184169;
184169->184170;
184170->184171;
184171->184172;
184172->184173;
184173->184174;
184174->184175;
184175->184176;
184176->184177;
}
184146
184172