digraph G {
subgraph clusterstage_44210 {
label="Stage 44210";
191775 [labelType="html" label="JDBCRDD [191775]<br>cache at <unknown>:0"];
subgraph cluster452230 {
label="WholeStageCodegen (1)";
191776 [labelType="html" label="MapPartitionsRDD [191776]<br>count at <unknown>:0"];
}
subgraph cluster452232 {
label="mapPartitionsInternal";
191777 [labelType="html" label="MapPartitionsRDD [191777]<br>count at <unknown>:0"];
}
subgraph cluster452233 {
label="mapPartitionsInternal";
191778 [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#17316669,supplier_id#17316670,entity_name#17316671,city#17316672,state#17316673,country#17316674,supplier_type#17316675,declaring_supplier_id#17316676,canonical_id#17316677,is_primary#17316678,threshold#17316679,create_date#17316680] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [191778] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster452290 {
label="InMemoryTableScan";
191799 [labelType="html" label="MapPartitionsRDD [191799]<br>count at <unknown>:0"];
191800 [labelType="html" label="MapPartitionsRDD [191800]<br>count at <unknown>:0"];
191801 [labelType="html" label="MapPartitionsRDD [191801]<br>count at <unknown>:0"];
}
subgraph cluster452286 {
label="WholeStageCodegen (1)";
191802 [labelType="html" label="MapPartitionsRDD [191802]<br>count at <unknown>:0"];
}
subgraph cluster452291 {
label="mapPartitionsInternal";
191803 [labelType="html" label="MapPartitionsRDD [191803]<br>count at <unknown>:0"];
}
subgraph cluster452292 {
label="mapPartitionsInternal";
191804 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#17316677)\n +- InMemoryTableScan [brand_context_id#17316669, supplier_id#17316670, canonical_id#17316677, is_primary#17316678, entity_name#17316671, city#17316672, state#17316673, country#17316674, threshold#17316679, create_date#17316680], [isnotnull(canonical_id#17316677)]\n +- InMemoryRelation [brand_context_id#17316669, supplier_id#17316670, entity_name#17316671, city#17316672, state#17316673, country#17316674, supplier_type#17316675, declaring_supplier_id#17316676, canonical_id#17316677, is_primary#17316678, threshold#17316679, create_date#17316680], 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 ... [191804] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster452298 {
label="InMemoryTableScan";
191805 [labelType="html" label="MapPartitionsRDD [191805]<br>count at <unknown>:0"];
191806 [labelType="html" label="MapPartitionsRDD [191806]<br>count at <unknown>:0"];
191807 [labelType="html" label="MapPartitionsRDD [191807]<br>count at <unknown>:0"];
}
subgraph cluster452294 {
label="WholeStageCodegen (1)";
191808 [labelType="html" label="MapPartitionsRDD [191808]<br>count at <unknown>:0"];
}
subgraph cluster452293 {
label="Exchange";
191809 [labelType="html" label="MapPartitionsRDD [191809]<br>count at <unknown>:0"];
}
}
191775->191776;
191776->191777;
191777->191778;
191778->191799;
191799->191800;
191800->191801;
191801->191802;
191802->191803;
191803->191804;
191804->191805;
191805->191806;
191806->191807;
191807->191808;
191808->191809;
}
191778
191804