digraph G {
subgraph clusterstage_37450 {
label="Stage 37450";
161549 [labelType="html" label="JDBCRDD [161549]<br>cache at <unknown>:0"];
subgraph cluster389295 {
label="WholeStageCodegen (1)";
161550 [labelType="html" label="MapPartitionsRDD [161550]<br>count at <unknown>:0"];
}
subgraph cluster389297 {
label="mapPartitionsInternal";
161551 [labelType="html" label="MapPartitionsRDD [161551]<br>count at <unknown>:0"];
}
subgraph cluster389298 {
label="mapPartitionsInternal";
161552 [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#15196136,supplier_id#15196137,entity_name#15196138,city#15196139,state#15196140,country#15196141,supplier_type#15196142,declaring_supplier_id#15196143,canonical_id#15196144,is_primary#15196145,threshold#15196146,create_date#15196147] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [161552] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster389355 {
label="InMemoryTableScan";
161573 [labelType="html" label="MapPartitionsRDD [161573]<br>count at <unknown>:0"];
161574 [labelType="html" label="MapPartitionsRDD [161574]<br>count at <unknown>:0"];
161575 [labelType="html" label="MapPartitionsRDD [161575]<br>count at <unknown>:0"];
}
subgraph cluster389351 {
label="WholeStageCodegen (1)";
161576 [labelType="html" label="MapPartitionsRDD [161576]<br>count at <unknown>:0"];
}
subgraph cluster389356 {
label="mapPartitionsInternal";
161577 [labelType="html" label="MapPartitionsRDD [161577]<br>count at <unknown>:0"];
}
subgraph cluster389357 {
label="mapPartitionsInternal";
161578 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#15196144)\n +- InMemoryTableScan [brand_context_id#15196136, supplier_id#15196137, canonical_id#15196144, is_primary#15196145, entity_name#15196138, city#15196139, state#15196140, country#15196141, threshold#15196146, create_date#15196147], [isnotnull(canonical_id#15196144)]\n +- InMemoryRelation [brand_context_id#15196136, supplier_id#15196137, entity_name#15196138, city#15196139, state#15196140, country#15196141, supplier_type#15196142, declaring_supplier_id#15196143, canonical_id#15196144, is_primary#15196145, threshold#15196146, create_date#15196147], 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 ... [161578] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster389363 {
label="InMemoryTableScan";
161579 [labelType="html" label="MapPartitionsRDD [161579]<br>count at <unknown>:0"];
161580 [labelType="html" label="MapPartitionsRDD [161580]<br>count at <unknown>:0"];
161581 [labelType="html" label="MapPartitionsRDD [161581]<br>count at <unknown>:0"];
}
subgraph cluster389359 {
label="WholeStageCodegen (1)";
161582 [labelType="html" label="MapPartitionsRDD [161582]<br>count at <unknown>:0"];
}
subgraph cluster389358 {
label="Exchange";
161583 [labelType="html" label="MapPartitionsRDD [161583]<br>count at <unknown>:0"];
}
}
161549->161550;
161550->161551;
161551->161552;
161552->161573;
161573->161574;
161574->161575;
161575->161576;
161576->161577;
161577->161578;
161578->161579;
161579->161580;
161580->161581;
161581->161582;
161582->161583;
}
161552
161578