digraph G {
subgraph clusterstage_42842 {
label="Stage 42842";
187052 [labelType="html" label="JDBCRDD [187052]<br>cache at <unknown>:0"];
subgraph cluster441214 {
label="WholeStageCodegen (1)";
187053 [labelType="html" label="MapPartitionsRDD [187053]<br>count at <unknown>:0"];
}
subgraph cluster441216 {
label="mapPartitionsInternal";
187054 [labelType="html" label="MapPartitionsRDD [187054]<br>count at <unknown>:0"];
}
subgraph cluster441217 {
label="mapPartitionsInternal";
187055 [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#16993178,supplier_id#16993179,entity_name#16993180,city#16993181,state#16993182,country#16993183,supplier_type#16993184,declaring_supplier_id#16993185,canonical_id#16993186,is_primary#16993187,threshold#16993188,create_date#16993189] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [187055] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster441274 {
label="InMemoryTableScan";
187076 [labelType="html" label="MapPartitionsRDD [187076]<br>count at <unknown>:0"];
187077 [labelType="html" label="MapPartitionsRDD [187077]<br>count at <unknown>:0"];
187078 [labelType="html" label="MapPartitionsRDD [187078]<br>count at <unknown>:0"];
}
subgraph cluster441270 {
label="WholeStageCodegen (1)";
187079 [labelType="html" label="MapPartitionsRDD [187079]<br>count at <unknown>:0"];
}
subgraph cluster441275 {
label="mapPartitionsInternal";
187080 [labelType="html" label="MapPartitionsRDD [187080]<br>count at <unknown>:0"];
}
subgraph cluster441276 {
label="mapPartitionsInternal";
187081 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#16993186)\n +- InMemoryTableScan [brand_context_id#16993178, supplier_id#16993179, canonical_id#16993186, is_primary#16993187, entity_name#16993180, city#16993181, state#16993182, country#16993183, threshold#16993188, create_date#16993189], [isnotnull(canonical_id#16993186)]\n +- InMemoryRelation [brand_context_id#16993178, supplier_id#16993179, entity_name#16993180, city#16993181, state#16993182, country#16993183, supplier_type#16993184, declaring_supplier_id#16993185, canonical_id#16993186, is_primary#16993187, threshold#16993188, create_date#16993189], 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 ... [187081] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster441282 {
label="InMemoryTableScan";
187082 [labelType="html" label="MapPartitionsRDD [187082]<br>count at <unknown>:0"];
187083 [labelType="html" label="MapPartitionsRDD [187083]<br>count at <unknown>:0"];
187084 [labelType="html" label="MapPartitionsRDD [187084]<br>count at <unknown>:0"];
}
subgraph cluster441278 {
label="WholeStageCodegen (1)";
187085 [labelType="html" label="MapPartitionsRDD [187085]<br>count at <unknown>:0"];
}
subgraph cluster441277 {
label="Exchange";
187086 [labelType="html" label="MapPartitionsRDD [187086]<br>count at <unknown>:0"];
}
}
187052->187053;
187053->187054;
187054->187055;
187055->187076;
187076->187077;
187077->187078;
187078->187079;
187079->187080;
187080->187081;
187081->187082;
187082->187083;
187083->187084;
187084->187085;
187085->187086;
}
187055
187081