digraph G {
subgraph clusterstage_933 {
label="Stage 933";
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 cluster7426 {
label="InMemoryTableScan";
3225 [labelType="html" label="MapPartitionsRDD [3225]<br>count at <unknown>:0"];
3226 [labelType="html" label="MapPartitionsRDD [3226]<br>count at <unknown>:0"];
3227 [labelType="html" label="MapPartitionsRDD [3227]<br>count at <unknown>:0"];
}
subgraph cluster7421 {
label="WholeStageCodegen (1)";
3228 [labelType="html" label="MapPartitionsRDD [3228]<br>count at <unknown>:0"];
}
subgraph cluster7427 {
label="mapPartitionsInternal";
3229 [labelType="html" label="MapPartitionsRDD [3229]<br>count at <unknown>:0"];
}
subgraph cluster7428 {
label="mapPartitionsInternal";
3230 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#265051, supplier_id#265052, entity_name#265053, city#265054, state#265055, country#265056, supplier_type#265057, declaring_supplier_id#265058, threshold#265061, create_date#265062]\n +- Filter isnull(canonical_id#265059)\n +- InMemoryTableScan [brand_context_id#265051, canonical_id#265059, city#265054, country#265056, create_date#265062, declaring_supplier_id#265058, entity_name#265053, state#265055, supplier_id#265052, supplier_type#265057, threshold#265061], [isnull(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.sup... [3230] [Cached]<br>count at <unknown>:0"];
}
}
3213->3214;
3214->3215;
3215->3216;
3216->3225;
3225->3226;
3226->3227;
3227->3228;
3228->3229;
3229->3230;
}
3216
3230