digraph G {
subgraph clusterstage_1443 {
label="Stage 1443";
4961 [labelType="html" label="JDBCRDD [4961]<br>cache at <unknown>:0"];
subgraph cluster11577 {
label="WholeStageCodegen (1)";
4962 [labelType="html" label="MapPartitionsRDD [4962]<br>count at <unknown>:0"];
}
subgraph cluster11579 {
label="mapPartitionsInternal";
4963 [labelType="html" label="MapPartitionsRDD [4963]<br>count at <unknown>:0"];
}
subgraph cluster11580 {
label="mapPartitionsInternal";
4964 [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#333177,supplier_id#333178,entity_name#333179,city#333180,state#333181,country#333182,supplier_type#333183,declaring_supplier_id#333184,canonical_id#333185,is_primary#333186,threshold#333187,create_date#333188] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [4964] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster11637 {
label="InMemoryTableScan";
4985 [labelType="html" label="MapPartitionsRDD [4985]<br>count at <unknown>:0"];
4986 [labelType="html" label="MapPartitionsRDD [4986]<br>count at <unknown>:0"];
4987 [labelType="html" label="MapPartitionsRDD [4987]<br>count at <unknown>:0"];
}
subgraph cluster11633 {
label="WholeStageCodegen (1)";
4988 [labelType="html" label="MapPartitionsRDD [4988]<br>count at <unknown>:0"];
}
subgraph cluster11638 {
label="mapPartitionsInternal";
4989 [labelType="html" label="MapPartitionsRDD [4989]<br>count at <unknown>:0"];
}
subgraph cluster11639 {
label="mapPartitionsInternal";
4990 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#333185)\n +- InMemoryTableScan [brand_context_id#333177, supplier_id#333178, canonical_id#333185, is_primary#333186, entity_name#333179, city#333180, state#333181, country#333182, threshold#333187, create_date#333188], [isnotnull(canonical_id#333185)]\n +- InMemoryRelation [brand_context_id#333177, supplier_id#333178, entity_name#333179, city#333180, state#333181, country#333182, supplier_type#333183, declaring_supplier_id#333184, canonical_id#333185, is_primary#333186, threshold#333187, create_date#333188], 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 v.canonical_id,\n v.is_prima... [4990] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster11645 {
label="InMemoryTableScan";
4991 [labelType="html" label="MapPartitionsRDD [4991]<br>count at <unknown>:0"];
4992 [labelType="html" label="MapPartitionsRDD [4992]<br>count at <unknown>:0"];
4993 [labelType="html" label="MapPartitionsRDD [4993]<br>count at <unknown>:0"];
}
subgraph cluster11641 {
label="WholeStageCodegen (1)";
4994 [labelType="html" label="MapPartitionsRDD [4994]<br>count at <unknown>:0"];
}
subgraph cluster11640 {
label="Exchange";
4995 [labelType="html" label="MapPartitionsRDD [4995]<br>count at <unknown>:0"];
}
}
4961->4962;
4962->4963;
4963->4964;
4964->4985;
4985->4986;
4986->4987;
4987->4988;
4988->4989;
4989->4990;
4990->4991;
4991->4992;
4992->4993;
4993->4994;
4994->4995;
}
4964
4990