digraph G {
subgraph clusterstage_85 {
label="Stage 85";
266 [labelType="html" label="JDBCRDD [266]<br>cache at <unknown>:0"];
subgraph cluster637 {
label="WholeStageCodegen (1)";
267 [labelType="html" label="MapPartitionsRDD [267]<br>count at <unknown>:0"];
}
subgraph cluster639 {
label="mapPartitionsInternal";
268 [labelType="html" label="MapPartitionsRDD [268]<br>count at <unknown>:0"];
}
subgraph cluster640 {
label="mapPartitionsInternal";
269 [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#10367,supplier_id#10368,entity_name#10369,city#10370,state#10371,country#10372,supplier_type#10373,declaring_supplier_id#10374,canonical_id#10375,is_primary#10376,threshold#10377,create_date#10378] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [269] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster697 {
label="InMemoryTableScan";
290 [labelType="html" label="MapPartitionsRDD [290]<br>count at <unknown>:0"];
291 [labelType="html" label="MapPartitionsRDD [291]<br>count at <unknown>:0"];
292 [labelType="html" label="MapPartitionsRDD [292]<br>count at <unknown>:0"];
}
subgraph cluster693 {
label="WholeStageCodegen (1)";
293 [labelType="html" label="MapPartitionsRDD [293]<br>count at <unknown>:0"];
}
subgraph cluster698 {
label="mapPartitionsInternal";
294 [labelType="html" label="MapPartitionsRDD [294]<br>count at <unknown>:0"];
}
subgraph cluster699 {
label="mapPartitionsInternal";
295 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#10375)\n +- InMemoryTableScan [brand_context_id#10367, supplier_id#10368, canonical_id#10375, is_primary#10376, entity_name#10369, city#10370, state#10371, country#10372, threshold#10377, create_date#10378], [isnotnull(canonical_id#10375)]\n +- InMemoryRelation [brand_context_id#10367, supplier_id#10368, entity_name#10369, city#10370, state#10371, country#10372, supplier_type#10373, declaring_supplier_id#10374, canonical_id#10375, is_primary#10376, threshold#10377, create_date#10378], 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_primary,\n COAL... [295] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster705 {
label="InMemoryTableScan";
296 [labelType="html" label="MapPartitionsRDD [296]<br>count at <unknown>:0"];
297 [labelType="html" label="MapPartitionsRDD [297]<br>count at <unknown>:0"];
298 [labelType="html" label="MapPartitionsRDD [298]<br>count at <unknown>:0"];
}
subgraph cluster701 {
label="WholeStageCodegen (1)";
299 [labelType="html" label="MapPartitionsRDD [299]<br>count at <unknown>:0"];
}
subgraph cluster700 {
label="Exchange";
300 [labelType="html" label="MapPartitionsRDD [300]<br>count at <unknown>:0"];
}
}
266->267;
267->268;
268->269;
269->290;
290->291;
291->292;
292->293;
293->294;
294->295;
295->296;
296->297;
297->298;
298->299;
299->300;
}
269
295