digraph G {
subgraph clusterstage_43705 {
label="Stage 43705";
190037 [labelType="html" label="JDBCRDD [190037]<br>cache at <unknown>:0"];
subgraph cluster448059 {
label="WholeStageCodegen (1)";
190038 [labelType="html" label="MapPartitionsRDD [190038]<br>count at <unknown>:0"];
}
subgraph cluster448061 {
label="mapPartitionsInternal";
190039 [labelType="html" label="MapPartitionsRDD [190039]<br>count at <unknown>:0"];
}
subgraph cluster448062 {
label="mapPartitionsInternal";
190040 [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#17249343,supplier_id#17249344,entity_name#17249345,city#17249346,state#17249347,country#17249348,supplier_type#17249349,declaring_supplier_id#17249350,canonical_id#17249351,is_primary#17249352,threshold#17249353,create_date#17249354] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [190040] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster448119 {
label="InMemoryTableScan";
190061 [labelType="html" label="MapPartitionsRDD [190061]<br>count at <unknown>:0"];
190062 [labelType="html" label="MapPartitionsRDD [190062]<br>count at <unknown>:0"];
190063 [labelType="html" label="MapPartitionsRDD [190063]<br>count at <unknown>:0"];
}
subgraph cluster448115 {
label="WholeStageCodegen (1)";
190064 [labelType="html" label="MapPartitionsRDD [190064]<br>count at <unknown>:0"];
}
subgraph cluster448120 {
label="mapPartitionsInternal";
190065 [labelType="html" label="MapPartitionsRDD [190065]<br>count at <unknown>:0"];
}
subgraph cluster448121 {
label="mapPartitionsInternal";
190066 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#17249351)\n +- InMemoryTableScan [brand_context_id#17249343, supplier_id#17249344, canonical_id#17249351, is_primary#17249352, entity_name#17249345, city#17249346, state#17249347, country#17249348, threshold#17249353, create_date#17249354], [isnotnull(canonical_id#17249351)]\n +- InMemoryRelation [brand_context_id#17249343, supplier_id#17249344, entity_name#17249345, city#17249346, state#17249347, country#17249348, supplier_type#17249349, declaring_supplier_id#17249350, canonical_id#17249351, is_primary#17249352, threshold#17249353, create_date#17249354], 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 ... [190066] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster448127 {
label="InMemoryTableScan";
190067 [labelType="html" label="MapPartitionsRDD [190067]<br>count at <unknown>:0"];
190068 [labelType="html" label="MapPartitionsRDD [190068]<br>count at <unknown>:0"];
190069 [labelType="html" label="MapPartitionsRDD [190069]<br>count at <unknown>:0"];
}
subgraph cluster448123 {
label="WholeStageCodegen (1)";
190070 [labelType="html" label="MapPartitionsRDD [190070]<br>count at <unknown>:0"];
}
subgraph cluster448122 {
label="Exchange";
190071 [labelType="html" label="MapPartitionsRDD [190071]<br>count at <unknown>:0"];
}
}
190037->190038;
190038->190039;
190039->190040;
190040->190061;
190061->190062;
190062->190063;
190063->190064;
190064->190065;
190065->190066;
190066->190067;
190067->190068;
190068->190069;
190069->190070;
190070->190071;
}
190040
190066