digraph G {
subgraph clusterstage_30927 {
label="Stage 30927";
132392 [labelType="html" label="JDBCRDD [132392]<br>cache at <unknown>:0"];
subgraph cluster328844 {
label="WholeStageCodegen (1)";
132393 [labelType="html" label="MapPartitionsRDD [132393]<br>count at <unknown>:0"];
}
subgraph cluster328846 {
label="mapPartitionsInternal";
132394 [labelType="html" label="MapPartitionsRDD [132394]<br>count at <unknown>:0"];
}
subgraph cluster328847 {
label="mapPartitionsInternal";
132395 [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#13216695,supplier_id#13216696,entity_name#13216697,city#13216698,state#13216699,country#13216700,supplier_type#13216701,declaring_supplier_id#13216702,canonical_id#13216703,is_primary#13216704,threshold#13216705,create_date#13216706] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [132395] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster328879 {
label="InMemoryTableScan";
132404 [labelType="html" label="MapPartitionsRDD [132404]<br>count at <unknown>:0"];
132405 [labelType="html" label="MapPartitionsRDD [132405]<br>count at <unknown>:0"];
132406 [labelType="html" label="MapPartitionsRDD [132406]<br>count at <unknown>:0"];
}
subgraph cluster328874 {
label="WholeStageCodegen (1)";
132407 [labelType="html" label="MapPartitionsRDD [132407]<br>count at <unknown>:0"];
}
subgraph cluster328880 {
label="mapPartitionsInternal";
132408 [labelType="html" label="MapPartitionsRDD [132408]<br>count at <unknown>:0"];
}
subgraph cluster328881 {
label="mapPartitionsInternal";
132409 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#13216695, supplier_id#13216696, entity_name#13216697, city#13216698, state#13216699, country#13216700, supplier_type#13216701, declaring_supplier_id#13216702, threshold#13216705, create_date#13216706]\n +- Filter isnull(canonical_id#13216703)\n +- InMemoryTableScan [brand_context_id#13216695, canonical_id#13216703, city#13216698, country#13216700, create_date#13216706, declaring_supplier_id#13216702, entity_name#13216697, state#13216699, supplier_id#13216696, supplier_type#13216701, threshold#13216705], [isnull(canonical_id#13216703)]\n +- InMemoryRelation [brand_context_id#13216695, supplier_id#13216696, entity_name#13216697, city#13216698, state#13216699, country#13216700, supplier_type#13216701, declaring_supplier_id#13216702, canonical_id#13216703, is_primary#13216704, threshold#13216705, create_date#13216706], StorageLevel(disk, memory, deserialized, 1 replicas)\n +- *(1) Scan JDBCRelation((\n SEL... [132409] [Cached]<br>count at <unknown>:0"];
}
}
132392->132393;
132393->132394;
132394->132395;
132395->132404;
132404->132405;
132405->132406;
132406->132407;
132407->132408;
132408->132409;
}
132395
132409