digraph G {
subgraph clusterstage_38417 {
label="Stage 38417";
164986 [labelType="html" label="JDBCRDD [164986]<br>cache at <unknown>:0"];
subgraph cluster397122 {
label="WholeStageCodegen (1)";
164987 [labelType="html" label="MapPartitionsRDD [164987]<br>count at <unknown>:0"];
}
subgraph cluster397124 {
label="mapPartitionsInternal";
164988 [labelType="html" label="MapPartitionsRDD [164988]<br>count at <unknown>:0"];
}
subgraph cluster397125 {
label="mapPartitionsInternal";
164989 [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#15526011,supplier_id#15526012,entity_name#15526013,city#15526014,state#15526015,country#15526016,supplier_type#15526017,declaring_supplier_id#15526018,canonical_id#15526019,is_primary#15526020,threshold#15526021,create_date#15526022] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [164989] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster397182 {
label="InMemoryTableScan";
165010 [labelType="html" label="MapPartitionsRDD [165010]<br>count at <unknown>:0"];
165011 [labelType="html" label="MapPartitionsRDD [165011]<br>count at <unknown>:0"];
165012 [labelType="html" label="MapPartitionsRDD [165012]<br>count at <unknown>:0"];
}
subgraph cluster397178 {
label="WholeStageCodegen (1)";
165013 [labelType="html" label="MapPartitionsRDD [165013]<br>count at <unknown>:0"];
}
subgraph cluster397183 {
label="mapPartitionsInternal";
165014 [labelType="html" label="MapPartitionsRDD [165014]<br>count at <unknown>:0"];
}
subgraph cluster397184 {
label="mapPartitionsInternal";
165015 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#15526019)\n +- InMemoryTableScan [brand_context_id#15526011, supplier_id#15526012, canonical_id#15526019, is_primary#15526020, entity_name#15526013, city#15526014, state#15526015, country#15526016, threshold#15526021, create_date#15526022], [isnotnull(canonical_id#15526019)]\n +- InMemoryRelation [brand_context_id#15526011, supplier_id#15526012, entity_name#15526013, city#15526014, state#15526015, country#15526016, supplier_type#15526017, declaring_supplier_id#15526018, canonical_id#15526019, is_primary#15526020, threshold#15526021, create_date#15526022], 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 ... [165015] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster397190 {
label="InMemoryTableScan";
165016 [labelType="html" label="MapPartitionsRDD [165016]<br>count at <unknown>:0"];
165017 [labelType="html" label="MapPartitionsRDD [165017]<br>count at <unknown>:0"];
165018 [labelType="html" label="MapPartitionsRDD [165018]<br>count at <unknown>:0"];
}
subgraph cluster397186 {
label="WholeStageCodegen (1)";
165019 [labelType="html" label="MapPartitionsRDD [165019]<br>count at <unknown>:0"];
}
subgraph cluster397185 {
label="Exchange";
165020 [labelType="html" label="MapPartitionsRDD [165020]<br>count at <unknown>:0"];
}
}
164986->164987;
164987->164988;
164988->164989;
164989->165010;
165010->165011;
165011->165012;
165012->165013;
165013->165014;
165014->165015;
165015->165016;
165016->165017;
165017->165018;
165018->165019;
165019->165020;
}
164989
165015