digraph G {
subgraph clusterstage_1186 {
label="Stage 1186";
4087 [labelType="html" label="JDBCRDD [4087]<br>cache at <unknown>:0"];
subgraph cluster9484 {
label="WholeStageCodegen (1)";
4088 [labelType="html" label="MapPartitionsRDD [4088]<br>count at <unknown>:0"];
}
subgraph cluster9486 {
label="mapPartitionsInternal";
4089 [labelType="html" label="MapPartitionsRDD [4089]<br>count at <unknown>:0"];
}
subgraph cluster9487 {
label="mapPartitionsInternal";
4090 [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#299114,supplier_id#299115,entity_name#299116,city#299117,state#299118,country#299119,supplier_type#299120,declaring_supplier_id#299121,canonical_id#299122,is_primary#299123,threshold#299124,create_date#299125] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [4090] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster9519 {
label="InMemoryTableScan";
4099 [labelType="html" label="MapPartitionsRDD [4099]<br>count at <unknown>:0"];
4100 [labelType="html" label="MapPartitionsRDD [4100]<br>count at <unknown>:0"];
4101 [labelType="html" label="MapPartitionsRDD [4101]<br>count at <unknown>:0"];
}
subgraph cluster9514 {
label="WholeStageCodegen (1)";
4102 [labelType="html" label="MapPartitionsRDD [4102]<br>count at <unknown>:0"];
}
subgraph cluster9520 {
label="mapPartitionsInternal";
4103 [labelType="html" label="MapPartitionsRDD [4103]<br>count at <unknown>:0"];
}
subgraph cluster9521 {
label="mapPartitionsInternal";
4104 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#299114, supplier_id#299115, entity_name#299116, city#299117, state#299118, country#299119, supplier_type#299120, declaring_supplier_id#299121, threshold#299124, create_date#299125]\n +- Filter isnull(canonical_id#299122)\n +- InMemoryTableScan [brand_context_id#299114, canonical_id#299122, city#299117, country#299119, create_date#299125, declaring_supplier_id#299121, entity_name#299116, state#299118, supplier_id#299115, supplier_type#299120, threshold#299124], [isnull(canonical_id#299122)]\n +- InMemoryRelation [brand_context_id#299114, supplier_id#299115, entity_name#299116, city#299117, state#299118, country#299119, supplier_type#299120, declaring_supplier_id#299121, canonical_id#299122, is_primary#299123, threshold#299124, create_date#299125], StorageLevel(disk, memory, deserialized, 1 replicas)\n +- *(1) Scan JDBCRelation((\n SELECT DISTINCT\n v.brand_context_id,\n v.sup... [4104] [Cached]<br>count at <unknown>:0"];
}
}
4087->4088;
4088->4089;
4089->4090;
4090->4099;
4099->4100;
4100->4101;
4101->4102;
4102->4103;
4103->4104;
}
4090
4104