digraph G {
subgraph clusterstage_40702 {
label="Stage 40702";
173562 [labelType="html" label="JDBCRDD [173562]<br>cache at <unknown>:0"];
subgraph cluster413402 {
label="WholeStageCodegen (1)";
173563 [labelType="html" label="MapPartitionsRDD [173563]<br>count at <unknown>:0"];
}
subgraph cluster413404 {
label="mapPartitionsInternal";
173564 [labelType="html" label="MapPartitionsRDD [173564]<br>count at <unknown>:0"];
}
subgraph cluster413405 {
label="mapPartitionsInternal";
173565 [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#20657552,supplier_id#20657553,entity_name#20657554,city#20657555,state#20657556,country#20657557,supplier_type#20657558,declaring_supplier_id#20657559,canonical_id#20657560,is_primary#20657561,threshold#20657562,create_date#20657563] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [173565] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster413462 {
label="InMemoryTableScan";
173586 [labelType="html" label="MapPartitionsRDD [173586]<br>count at <unknown>:0"];
173587 [labelType="html" label="MapPartitionsRDD [173587]<br>count at <unknown>:0"];
173588 [labelType="html" label="MapPartitionsRDD [173588]<br>count at <unknown>:0"];
}
subgraph cluster413458 {
label="WholeStageCodegen (1)";
173589 [labelType="html" label="MapPartitionsRDD [173589]<br>count at <unknown>:0"];
}
subgraph cluster413463 {
label="mapPartitionsInternal";
173590 [labelType="html" label="MapPartitionsRDD [173590]<br>count at <unknown>:0"];
}
subgraph cluster413464 {
label="mapPartitionsInternal";
173591 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#20657560)\n +- InMemoryTableScan [brand_context_id#20657552, supplier_id#20657553, canonical_id#20657560, is_primary#20657561, entity_name#20657554, city#20657555, state#20657556, country#20657557, threshold#20657562, create_date#20657563], [isnotnull(canonical_id#20657560)]\n +- InMemoryRelation [brand_context_id#20657552, supplier_id#20657553, entity_name#20657554, city#20657555, state#20657556, country#20657557, supplier_type#20657558, declaring_supplier_id#20657559, canonical_id#20657560, is_primary#20657561, threshold#20657562, create_date#20657563], 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 ... [173591] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster413470 {
label="InMemoryTableScan";
173592 [labelType="html" label="MapPartitionsRDD [173592]<br>count at <unknown>:0"];
173593 [labelType="html" label="MapPartitionsRDD [173593]<br>count at <unknown>:0"];
173594 [labelType="html" label="MapPartitionsRDD [173594]<br>count at <unknown>:0"];
}
subgraph cluster413466 {
label="WholeStageCodegen (1)";
173595 [labelType="html" label="MapPartitionsRDD [173595]<br>count at <unknown>:0"];
}
subgraph cluster413465 {
label="Exchange";
173596 [labelType="html" label="MapPartitionsRDD [173596]<br>count at <unknown>:0"];
}
}
173562->173563;
173563->173564;
173564->173565;
173565->173586;
173586->173587;
173587->173588;
173588->173589;
173589->173590;
173590->173591;
173591->173592;
173592->173593;
173593->173594;
173594->173595;
173595->173596;
}
173565
173591