digraph G {
subgraph clusterstage_28611 {
label="Stage 28611";
124266 [labelType="html" label="JDBCRDD [124266]<br>cache at <unknown>:0"];
subgraph cluster310145 {
label="WholeStageCodegen (1)";
124267 [labelType="html" label="MapPartitionsRDD [124267]<br>count at <unknown>:0"];
}
subgraph cluster310147 {
label="mapPartitionsInternal";
124268 [labelType="html" label="MapPartitionsRDD [124268]<br>count at <unknown>:0"];
}
subgraph cluster310148 {
label="mapPartitionsInternal";
124269 [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#12563310,supplier_id#12563311,entity_name#12563312,city#12563313,state#12563314,country#12563315,supplier_type#12563316,declaring_supplier_id#12563317,canonical_id#12563318,is_primary#12563319,threshold#12563320,create_date#12563321] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [124269] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster310205 {
label="InMemoryTableScan";
124290 [labelType="html" label="MapPartitionsRDD [124290]<br>count at <unknown>:0"];
124291 [labelType="html" label="MapPartitionsRDD [124291]<br>count at <unknown>:0"];
124292 [labelType="html" label="MapPartitionsRDD [124292]<br>count at <unknown>:0"];
}
subgraph cluster310201 {
label="WholeStageCodegen (1)";
124293 [labelType="html" label="MapPartitionsRDD [124293]<br>count at <unknown>:0"];
}
subgraph cluster310206 {
label="mapPartitionsInternal";
124294 [labelType="html" label="MapPartitionsRDD [124294]<br>count at <unknown>:0"];
}
subgraph cluster310207 {
label="mapPartitionsInternal";
124295 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#12563318)\n +- InMemoryTableScan [brand_context_id#12563310, supplier_id#12563311, canonical_id#12563318, is_primary#12563319, entity_name#12563312, city#12563313, state#12563314, country#12563315, threshold#12563320, create_date#12563321], [isnotnull(canonical_id#12563318)]\n +- InMemoryRelation [brand_context_id#12563310, supplier_id#12563311, entity_name#12563312, city#12563313, state#12563314, country#12563315, supplier_type#12563316, declaring_supplier_id#12563317, canonical_id#12563318, is_primary#12563319, threshold#12563320, create_date#12563321], 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 ... [124295] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster310213 {
label="InMemoryTableScan";
124296 [labelType="html" label="MapPartitionsRDD [124296]<br>count at <unknown>:0"];
124297 [labelType="html" label="MapPartitionsRDD [124297]<br>count at <unknown>:0"];
124298 [labelType="html" label="MapPartitionsRDD [124298]<br>count at <unknown>:0"];
}
subgraph cluster310209 {
label="WholeStageCodegen (1)";
124299 [labelType="html" label="MapPartitionsRDD [124299]<br>count at <unknown>:0"];
}
subgraph cluster310208 {
label="Exchange";
124300 [labelType="html" label="MapPartitionsRDD [124300]<br>count at <unknown>:0"];
}
}
124266->124267;
124267->124268;
124268->124269;
124269->124290;
124290->124291;
124291->124292;
124292->124293;
124293->124294;
124294->124295;
124295->124296;
124296->124297;
124297->124298;
124298->124299;
124299->124300;
}
124269
124295