digraph G {
subgraph clusterstage_44101 {
label="Stage 44101";
191405 [labelType="html" label="JDBCRDD [191405]<br>cache at <unknown>:0"];
subgraph cluster451335 {
label="WholeStageCodegen (1)";
191406 [labelType="html" label="MapPartitionsRDD [191406]<br>count at <unknown>:0"];
}
subgraph cluster451337 {
label="mapPartitionsInternal";
191407 [labelType="html" label="MapPartitionsRDD [191407]<br>count at <unknown>:0"];
}
subgraph cluster451338 {
label="mapPartitionsInternal";
191408 [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#17302659,supplier_id#17302660,entity_name#17302661,city#17302662,state#17302663,country#17302664,supplier_type#17302665,declaring_supplier_id#17302666,canonical_id#17302667,is_primary#17302668,threshold#17302669,create_date#17302670] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [191408] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster451395 {
label="InMemoryTableScan";
191429 [labelType="html" label="MapPartitionsRDD [191429]<br>count at <unknown>:0"];
191430 [labelType="html" label="MapPartitionsRDD [191430]<br>count at <unknown>:0"];
191431 [labelType="html" label="MapPartitionsRDD [191431]<br>count at <unknown>:0"];
}
subgraph cluster451391 {
label="WholeStageCodegen (1)";
191432 [labelType="html" label="MapPartitionsRDD [191432]<br>count at <unknown>:0"];
}
subgraph cluster451396 {
label="mapPartitionsInternal";
191433 [labelType="html" label="MapPartitionsRDD [191433]<br>count at <unknown>:0"];
}
subgraph cluster451397 {
label="mapPartitionsInternal";
191434 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#17302667)\n +- InMemoryTableScan [brand_context_id#17302659, supplier_id#17302660, canonical_id#17302667, is_primary#17302668, entity_name#17302661, city#17302662, state#17302663, country#17302664, threshold#17302669, create_date#17302670], [isnotnull(canonical_id#17302667)]\n +- InMemoryRelation [brand_context_id#17302659, supplier_id#17302660, entity_name#17302661, city#17302662, state#17302663, country#17302664, supplier_type#17302665, declaring_supplier_id#17302666, canonical_id#17302667, is_primary#17302668, threshold#17302669, create_date#17302670], 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 ... [191434] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster451403 {
label="InMemoryTableScan";
191435 [labelType="html" label="MapPartitionsRDD [191435]<br>count at <unknown>:0"];
191436 [labelType="html" label="MapPartitionsRDD [191436]<br>count at <unknown>:0"];
191437 [labelType="html" label="MapPartitionsRDD [191437]<br>count at <unknown>:0"];
}
subgraph cluster451399 {
label="WholeStageCodegen (1)";
191438 [labelType="html" label="MapPartitionsRDD [191438]<br>count at <unknown>:0"];
}
subgraph cluster451398 {
label="Exchange";
191439 [labelType="html" label="MapPartitionsRDD [191439]<br>count at <unknown>:0"];
}
}
191405->191406;
191406->191407;
191407->191408;
191408->191429;
191429->191430;
191430->191431;
191431->191432;
191432->191433;
191433->191434;
191434->191435;
191435->191436;
191436->191437;
191437->191438;
191438->191439;
}
191408
191434