digraph G {
subgraph clusterstage_40669 {
label="Stage 40669";
173448 [labelType="html" label="JDBCRDD [173448]<br>cache at <unknown>:0"];
subgraph cluster413129 {
label="WholeStageCodegen (1)";
173449 [labelType="html" label="MapPartitionsRDD [173449]<br>count at <unknown>:0"];
}
subgraph cluster413131 {
label="mapPartitionsInternal";
173450 [labelType="html" label="MapPartitionsRDD [173450]<br>count at <unknown>:0"];
}
subgraph cluster413132 {
label="mapPartitionsInternal";
173451 [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#20653109,supplier_id#20653110,entity_name#20653111,city#20653112,state#20653113,country#20653114,supplier_type#20653115,declaring_supplier_id#20653116,canonical_id#20653117,is_primary#20653118,threshold#20653119,create_date#20653120] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [173451] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster413189 {
label="InMemoryTableScan";
173472 [labelType="html" label="MapPartitionsRDD [173472]<br>count at <unknown>:0"];
173473 [labelType="html" label="MapPartitionsRDD [173473]<br>count at <unknown>:0"];
173474 [labelType="html" label="MapPartitionsRDD [173474]<br>count at <unknown>:0"];
}
subgraph cluster413185 {
label="WholeStageCodegen (1)";
173475 [labelType="html" label="MapPartitionsRDD [173475]<br>count at <unknown>:0"];
}
subgraph cluster413190 {
label="mapPartitionsInternal";
173476 [labelType="html" label="MapPartitionsRDD [173476]<br>count at <unknown>:0"];
}
subgraph cluster413191 {
label="mapPartitionsInternal";
173477 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#20653117)\n +- InMemoryTableScan [brand_context_id#20653109, supplier_id#20653110, canonical_id#20653117, is_primary#20653118, entity_name#20653111, city#20653112, state#20653113, country#20653114, threshold#20653119, create_date#20653120], [isnotnull(canonical_id#20653117)]\n +- InMemoryRelation [brand_context_id#20653109, supplier_id#20653110, entity_name#20653111, city#20653112, state#20653113, country#20653114, supplier_type#20653115, declaring_supplier_id#20653116, canonical_id#20653117, is_primary#20653118, threshold#20653119, create_date#20653120], 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 ... [173477] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster413197 {
label="InMemoryTableScan";
173478 [labelType="html" label="MapPartitionsRDD [173478]<br>count at <unknown>:0"];
173479 [labelType="html" label="MapPartitionsRDD [173479]<br>count at <unknown>:0"];
173480 [labelType="html" label="MapPartitionsRDD [173480]<br>count at <unknown>:0"];
}
subgraph cluster413193 {
label="WholeStageCodegen (1)";
173481 [labelType="html" label="MapPartitionsRDD [173481]<br>count at <unknown>:0"];
}
subgraph cluster413192 {
label="Exchange";
173482 [labelType="html" label="MapPartitionsRDD [173482]<br>count at <unknown>:0"];
}
}
173448->173449;
173449->173450;
173450->173451;
173451->173472;
173472->173473;
173473->173474;
173474->173475;
173475->173476;
173476->173477;
173477->173478;
173478->173479;
173479->173480;
173480->173481;
173481->173482;
}
173451
173477