digraph G {
subgraph clusterstage_37460 {
label="Stage 37460";
161587 [labelType="html" label="JDBCRDD [161587]<br>cache at <unknown>:0"];
subgraph cluster389386 {
label="WholeStageCodegen (1)";
161588 [labelType="html" label="MapPartitionsRDD [161588]<br>count at <unknown>:0"];
}
subgraph cluster389388 {
label="mapPartitionsInternal";
161589 [labelType="html" label="MapPartitionsRDD [161589]<br>count at <unknown>:0"];
}
subgraph cluster389389 {
label="mapPartitionsInternal";
161590 [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#15197617,supplier_id#15197618,entity_name#15197619,city#15197620,state#15197621,country#15197622,supplier_type#15197623,declaring_supplier_id#15197624,canonical_id#15197625,is_primary#15197626,threshold#15197627,create_date#15197628] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [161590] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster389446 {
label="InMemoryTableScan";
161611 [labelType="html" label="MapPartitionsRDD [161611]<br>count at <unknown>:0"];
161612 [labelType="html" label="MapPartitionsRDD [161612]<br>count at <unknown>:0"];
161613 [labelType="html" label="MapPartitionsRDD [161613]<br>count at <unknown>:0"];
}
subgraph cluster389442 {
label="WholeStageCodegen (1)";
161614 [labelType="html" label="MapPartitionsRDD [161614]<br>count at <unknown>:0"];
}
subgraph cluster389447 {
label="mapPartitionsInternal";
161615 [labelType="html" label="MapPartitionsRDD [161615]<br>count at <unknown>:0"];
}
subgraph cluster389448 {
label="mapPartitionsInternal";
161616 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#15197625)\n +- InMemoryTableScan [brand_context_id#15197617, supplier_id#15197618, canonical_id#15197625, is_primary#15197626, entity_name#15197619, city#15197620, state#15197621, country#15197622, threshold#15197627, create_date#15197628], [isnotnull(canonical_id#15197625)]\n +- InMemoryRelation [brand_context_id#15197617, supplier_id#15197618, entity_name#15197619, city#15197620, state#15197621, country#15197622, supplier_type#15197623, declaring_supplier_id#15197624, canonical_id#15197625, is_primary#15197626, threshold#15197627, create_date#15197628], 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 ... [161616] [Cached]<br>count at <unknown>:0"];
}
}
161587->161588;
161588->161589;
161589->161590;
161590->161611;
161611->161612;
161612->161613;
161613->161614;
161614->161615;
161615->161616;
}
161590
161616