digraph G {
subgraph clusterstage_937 {
label="Stage 937";
3213 [labelType="html" label="JDBCRDD [3213]<br>cache at <unknown>:0"];
subgraph cluster7391 {
label="WholeStageCodegen (1)";
3214 [labelType="html" label="MapPartitionsRDD [3214]<br>count at <unknown>:0"];
}
subgraph cluster7393 {
label="mapPartitionsInternal";
3215 [labelType="html" label="MapPartitionsRDD [3215]<br>count at <unknown>:0"];
}
subgraph cluster7394 {
label="mapPartitionsInternal";
3216 [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#265051,supplier_id#265052,entity_name#265053,city#265054,state#265055,country#265056,supplier_type#265057,declaring_supplier_id#265058,canonical_id#265059,is_primary#265060,threshold#265061,create_date#265062] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [3216] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster7451 {
label="InMemoryTableScan";
3237 [labelType="html" label="MapPartitionsRDD [3237]<br>count at <unknown>:0"];
3238 [labelType="html" label="MapPartitionsRDD [3238]<br>count at <unknown>:0"];
3239 [labelType="html" label="MapPartitionsRDD [3239]<br>count at <unknown>:0"];
}
subgraph cluster7447 {
label="WholeStageCodegen (1)";
3240 [labelType="html" label="MapPartitionsRDD [3240]<br>count at <unknown>:0"];
}
subgraph cluster7452 {
label="mapPartitionsInternal";
3241 [labelType="html" label="MapPartitionsRDD [3241]<br>count at <unknown>:0"];
}
subgraph cluster7453 {
label="mapPartitionsInternal";
3242 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#265059)\n +- InMemoryTableScan [brand_context_id#265051, supplier_id#265052, canonical_id#265059, is_primary#265060, entity_name#265053, city#265054, state#265055, country#265056, threshold#265061, create_date#265062], [isnotnull(canonical_id#265059)]\n +- InMemoryRelation [brand_context_id#265051, supplier_id#265052, entity_name#265053, city#265054, state#265055, country#265056, supplier_type#265057, declaring_supplier_id#265058, canonical_id#265059, is_primary#265060, threshold#265061, create_date#265062], 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... [3242] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster7459 {
label="InMemoryTableScan";
3243 [labelType="html" label="MapPartitionsRDD [3243]<br>count at <unknown>:0"];
3244 [labelType="html" label="MapPartitionsRDD [3244]<br>count at <unknown>:0"];
3245 [labelType="html" label="MapPartitionsRDD [3245]<br>count at <unknown>:0"];
}
subgraph cluster7455 {
label="WholeStageCodegen (1)";
3246 [labelType="html" label="MapPartitionsRDD [3246]<br>count at <unknown>:0"];
}
subgraph cluster7454 {
label="Exchange";
3247 [labelType="html" label="MapPartitionsRDD [3247]<br>count at <unknown>:0"];
}
}
3213->3214;
3214->3215;
3215->3216;
3216->3237;
3237->3238;
3238->3239;
3239->3240;
3240->3241;
3241->3242;
3242->3243;
3243->3244;
3244->3245;
3245->3246;
3246->3247;
}
3216
3242