digraph G {
subgraph clusterstage_1058 {
label="Stage 1058";
3631 [labelType="html" label="JDBCRDD [3631]<br>cache at <unknown>:0"];
subgraph cluster8392 {
label="WholeStageCodegen (1)";
3632 [labelType="html" label="MapPartitionsRDD [3632]<br>count at <unknown>:0"];
}
subgraph cluster8394 {
label="mapPartitionsInternal";
3633 [labelType="html" label="MapPartitionsRDD [3633]<br>count at <unknown>:0"];
}
subgraph cluster8395 {
label="mapPartitionsInternal";
3634 [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#281342,supplier_id#281343,entity_name#281344,city#281345,state#281346,country#281347,supplier_type#281348,declaring_supplier_id#281349,canonical_id#281350,is_primary#281351,threshold#281352,create_date#281353] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [3634] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster8452 {
label="InMemoryTableScan";
3655 [labelType="html" label="MapPartitionsRDD [3655]<br>count at <unknown>:0"];
3656 [labelType="html" label="MapPartitionsRDD [3656]<br>count at <unknown>:0"];
3657 [labelType="html" label="MapPartitionsRDD [3657]<br>count at <unknown>:0"];
}
subgraph cluster8448 {
label="WholeStageCodegen (1)";
3658 [labelType="html" label="MapPartitionsRDD [3658]<br>count at <unknown>:0"];
}
subgraph cluster8453 {
label="mapPartitionsInternal";
3659 [labelType="html" label="MapPartitionsRDD [3659]<br>count at <unknown>:0"];
}
subgraph cluster8454 {
label="mapPartitionsInternal";
3660 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#281350)\n +- InMemoryTableScan [brand_context_id#281342, supplier_id#281343, canonical_id#281350, is_primary#281351, entity_name#281344, city#281345, state#281346, country#281347, threshold#281352, create_date#281353], [isnotnull(canonical_id#281350)]\n +- InMemoryRelation [brand_context_id#281342, supplier_id#281343, entity_name#281344, city#281345, state#281346, country#281347, supplier_type#281348, declaring_supplier_id#281349, canonical_id#281350, is_primary#281351, threshold#281352, create_date#281353], 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... [3660] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster8460 {
label="InMemoryTableScan";
3661 [labelType="html" label="MapPartitionsRDD [3661]<br>count at <unknown>:0"];
3662 [labelType="html" label="MapPartitionsRDD [3662]<br>count at <unknown>:0"];
3663 [labelType="html" label="MapPartitionsRDD [3663]<br>count at <unknown>:0"];
}
subgraph cluster8456 {
label="WholeStageCodegen (1)";
3664 [labelType="html" label="MapPartitionsRDD [3664]<br>count at <unknown>:0"];
}
subgraph cluster8455 {
label="Exchange";
3665 [labelType="html" label="MapPartitionsRDD [3665]<br>count at <unknown>:0"];
}
}
3631->3632;
3632->3633;
3633->3634;
3634->3655;
3655->3656;
3656->3657;
3657->3658;
3658->3659;
3659->3660;
3660->3661;
3661->3662;
3662->3663;
3663->3664;
3664->3665;
}
3634
3660