digraph G {
subgraph clusterstage_34988 {
label="Stage 34988";
153059 [labelType="html" label="JDBCRDD [153059]<br>cache at <unknown>:0"];
subgraph cluster369469 {
label="WholeStageCodegen (1)";
153060 [labelType="html" label="MapPartitionsRDD [153060]<br>count at <unknown>:0"];
}
subgraph cluster369471 {
label="mapPartitionsInternal";
153061 [labelType="html" label="MapPartitionsRDD [153061]<br>count at <unknown>:0"];
}
subgraph cluster369472 {
label="mapPartitionsInternal";
153062 [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#14587460,supplier_id#14587461,entity_name#14587462,city#14587463,state#14587464,country#14587465,supplier_type#14587466,declaring_supplier_id#14587467,canonical_id#14587468,is_primary#14587469,threshold#14587470,create_date#14587471] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [153062] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster369529 {
label="InMemoryTableScan";
153083 [labelType="html" label="MapPartitionsRDD [153083]<br>count at <unknown>:0"];
153084 [labelType="html" label="MapPartitionsRDD [153084]<br>count at <unknown>:0"];
153085 [labelType="html" label="MapPartitionsRDD [153085]<br>count at <unknown>:0"];
}
subgraph cluster369525 {
label="WholeStageCodegen (1)";
153086 [labelType="html" label="MapPartitionsRDD [153086]<br>count at <unknown>:0"];
}
subgraph cluster369530 {
label="mapPartitionsInternal";
153087 [labelType="html" label="MapPartitionsRDD [153087]<br>count at <unknown>:0"];
}
subgraph cluster369531 {
label="mapPartitionsInternal";
153088 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#14587468)\n +- InMemoryTableScan [brand_context_id#14587460, supplier_id#14587461, canonical_id#14587468, is_primary#14587469, entity_name#14587462, city#14587463, state#14587464, country#14587465, threshold#14587470, create_date#14587471], [isnotnull(canonical_id#14587468)]\n +- InMemoryRelation [brand_context_id#14587460, supplier_id#14587461, entity_name#14587462, city#14587463, state#14587464, country#14587465, supplier_type#14587466, declaring_supplier_id#14587467, canonical_id#14587468, is_primary#14587469, threshold#14587470, create_date#14587471], 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 ... [153088] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster369537 {
label="InMemoryTableScan";
153089 [labelType="html" label="MapPartitionsRDD [153089]<br>count at <unknown>:0"];
153090 [labelType="html" label="MapPartitionsRDD [153090]<br>count at <unknown>:0"];
153091 [labelType="html" label="MapPartitionsRDD [153091]<br>count at <unknown>:0"];
}
subgraph cluster369533 {
label="WholeStageCodegen (1)";
153092 [labelType="html" label="MapPartitionsRDD [153092]<br>count at <unknown>:0"];
}
subgraph cluster369532 {
label="Exchange";
153093 [labelType="html" label="MapPartitionsRDD [153093]<br>count at <unknown>:0"];
}
}
153059->153060;
153060->153061;
153061->153062;
153062->153083;
153083->153084;
153084->153085;
153085->153086;
153086->153087;
153087->153088;
153088->153089;
153089->153090;
153090->153091;
153091->153092;
153092->153093;
}
153062
153088