digraph G {
subgraph clusterstage_30872 {
label="Stage 30872";
132202 [labelType="html" label="JDBCRDD [132202]<br>cache at <unknown>:0"];
subgraph cluster328389 {
label="WholeStageCodegen (1)";
132203 [labelType="html" label="MapPartitionsRDD [132203]<br>count at <unknown>:0"];
}
subgraph cluster328391 {
label="mapPartitionsInternal";
132204 [labelType="html" label="MapPartitionsRDD [132204]<br>count at <unknown>:0"];
}
subgraph cluster328392 {
label="mapPartitionsInternal";
132205 [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#13209290,supplier_id#13209291,entity_name#13209292,city#13209293,state#13209294,country#13209295,supplier_type#13209296,declaring_supplier_id#13209297,canonical_id#13209298,is_primary#13209299,threshold#13209300,create_date#13209301] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [132205] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster328424 {
label="InMemoryTableScan";
132214 [labelType="html" label="MapPartitionsRDD [132214]<br>count at <unknown>:0"];
132215 [labelType="html" label="MapPartitionsRDD [132215]<br>count at <unknown>:0"];
132216 [labelType="html" label="MapPartitionsRDD [132216]<br>count at <unknown>:0"];
}
subgraph cluster328419 {
label="WholeStageCodegen (1)";
132217 [labelType="html" label="MapPartitionsRDD [132217]<br>count at <unknown>:0"];
}
subgraph cluster328425 {
label="mapPartitionsInternal";
132218 [labelType="html" label="MapPartitionsRDD [132218]<br>count at <unknown>:0"];
}
subgraph cluster328426 {
label="mapPartitionsInternal";
132219 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#13209290, supplier_id#13209291, entity_name#13209292, city#13209293, state#13209294, country#13209295, supplier_type#13209296, declaring_supplier_id#13209297, threshold#13209300, create_date#13209301]\n +- Filter isnull(canonical_id#13209298)\n +- InMemoryTableScan [brand_context_id#13209290, canonical_id#13209298, city#13209293, country#13209295, create_date#13209301, declaring_supplier_id#13209297, entity_name#13209292, state#13209294, supplier_id#13209291, supplier_type#13209296, threshold#13209300], [isnull(canonical_id#13209298)]\n +- InMemoryRelation [brand_context_id#13209290, supplier_id#13209291, entity_name#13209292, city#13209293, state#13209294, country#13209295, supplier_type#13209296, declaring_supplier_id#13209297, canonical_id#13209298, is_primary#13209299, threshold#13209300, create_date#13209301], StorageLevel(disk, memory, deserialized, 1 replicas)\n +- *(1) Scan JDBCRelation((\n SEL... [132219] [Cached]<br>count at <unknown>:0"];
}
}
132202->132203;
132203->132204;
132204->132205;
132205->132214;
132214->132215;
132215->132216;
132216->132217;
132217->132218;
132218->132219;
}
132205
132219