digraph G {
subgraph clusterstage_926 {
label="Stage 926";
3175 [labelType="html" label="JDBCRDD [3175]<br>cache at <unknown>:0"];
subgraph cluster7300 {
label="WholeStageCodegen (1)";
3176 [labelType="html" label="MapPartitionsRDD [3176]<br>count at <unknown>:0"];
}
subgraph cluster7302 {
label="mapPartitionsInternal";
3177 [labelType="html" label="MapPartitionsRDD [3177]<br>count at <unknown>:0"];
}
subgraph cluster7303 {
label="mapPartitionsInternal";
3178 [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#263570,supplier_id#263571,entity_name#263572,city#263573,state#263574,country#263575,supplier_type#263576,declaring_supplier_id#263577,canonical_id#263578,is_primary#263579,threshold#263580,create_date#263581] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [3178] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster7360 {
label="InMemoryTableScan";
3199 [labelType="html" label="MapPartitionsRDD [3199]<br>count at <unknown>:0"];
3200 [labelType="html" label="MapPartitionsRDD [3200]<br>count at <unknown>:0"];
3201 [labelType="html" label="MapPartitionsRDD [3201]<br>count at <unknown>:0"];
}
subgraph cluster7356 {
label="WholeStageCodegen (1)";
3202 [labelType="html" label="MapPartitionsRDD [3202]<br>count at <unknown>:0"];
}
subgraph cluster7361 {
label="mapPartitionsInternal";
3203 [labelType="html" label="MapPartitionsRDD [3203]<br>count at <unknown>:0"];
}
subgraph cluster7362 {
label="mapPartitionsInternal";
3204 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#263578)\n +- InMemoryTableScan [brand_context_id#263570, supplier_id#263571, canonical_id#263578, is_primary#263579, entity_name#263572, city#263573, state#263574, country#263575, threshold#263580, create_date#263581], [isnotnull(canonical_id#263578)]\n +- InMemoryRelation [brand_context_id#263570, supplier_id#263571, entity_name#263572, city#263573, state#263574, country#263575, supplier_type#263576, declaring_supplier_id#263577, canonical_id#263578, is_primary#263579, threshold#263580, create_date#263581], 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... [3204] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster7368 {
label="InMemoryTableScan";
3205 [labelType="html" label="MapPartitionsRDD [3205]<br>count at <unknown>:0"];
3206 [labelType="html" label="MapPartitionsRDD [3206]<br>count at <unknown>:0"];
3207 [labelType="html" label="MapPartitionsRDD [3207]<br>count at <unknown>:0"];
}
subgraph cluster7364 {
label="WholeStageCodegen (1)";
3208 [labelType="html" label="MapPartitionsRDD [3208]<br>count at <unknown>:0"];
}
subgraph cluster7363 {
label="Exchange";
3209 [labelType="html" label="MapPartitionsRDD [3209]<br>count at <unknown>:0"];
}
}
3175->3176;
3176->3177;
3177->3178;
3178->3199;
3199->3200;
3200->3201;
3201->3202;
3202->3203;
3203->3204;
3204->3205;
3205->3206;
3206->3207;
3207->3208;
3208->3209;
}
3178
3204