digraph G {
subgraph clusterstage_28787 {
label="Stage 28787";
124874 [labelType="html" label="JDBCRDD [124874]<br>cache at <unknown>:0"];
subgraph cluster311601 {
label="WholeStageCodegen (1)";
124875 [labelType="html" label="MapPartitionsRDD [124875]<br>count at <unknown>:0"];
}
subgraph cluster311603 {
label="mapPartitionsInternal";
124876 [labelType="html" label="MapPartitionsRDD [124876]<br>count at <unknown>:0"];
}
subgraph cluster311604 {
label="mapPartitionsInternal";
124877 [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#12587006,supplier_id#12587007,entity_name#12587008,city#12587009,state#12587010,country#12587011,supplier_type#12587012,declaring_supplier_id#12587013,canonical_id#12587014,is_primary#12587015,threshold#12587016,create_date#12587017] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [124877] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster311661 {
label="InMemoryTableScan";
124898 [labelType="html" label="MapPartitionsRDD [124898]<br>count at <unknown>:0"];
124899 [labelType="html" label="MapPartitionsRDD [124899]<br>count at <unknown>:0"];
124900 [labelType="html" label="MapPartitionsRDD [124900]<br>count at <unknown>:0"];
}
subgraph cluster311657 {
label="WholeStageCodegen (1)";
124901 [labelType="html" label="MapPartitionsRDD [124901]<br>count at <unknown>:0"];
}
subgraph cluster311662 {
label="mapPartitionsInternal";
124902 [labelType="html" label="MapPartitionsRDD [124902]<br>count at <unknown>:0"];
}
subgraph cluster311663 {
label="mapPartitionsInternal";
124903 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#12587014)\n +- InMemoryTableScan [brand_context_id#12587006, supplier_id#12587007, canonical_id#12587014, is_primary#12587015, entity_name#12587008, city#12587009, state#12587010, country#12587011, threshold#12587016, create_date#12587017], [isnotnull(canonical_id#12587014)]\n +- InMemoryRelation [brand_context_id#12587006, supplier_id#12587007, entity_name#12587008, city#12587009, state#12587010, country#12587011, supplier_type#12587012, declaring_supplier_id#12587013, canonical_id#12587014, is_primary#12587015, threshold#12587016, create_date#12587017], 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 ... [124903] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster311669 {
label="InMemoryTableScan";
124904 [labelType="html" label="MapPartitionsRDD [124904]<br>count at <unknown>:0"];
124905 [labelType="html" label="MapPartitionsRDD [124905]<br>count at <unknown>:0"];
124906 [labelType="html" label="MapPartitionsRDD [124906]<br>count at <unknown>:0"];
}
subgraph cluster311665 {
label="WholeStageCodegen (1)";
124907 [labelType="html" label="MapPartitionsRDD [124907]<br>count at <unknown>:0"];
}
subgraph cluster311664 {
label="Exchange";
124908 [labelType="html" label="MapPartitionsRDD [124908]<br>count at <unknown>:0"];
}
}
124874->124875;
124875->124876;
124876->124877;
124877->124898;
124898->124899;
124899->124900;
124900->124901;
124901->124902;
124902->124903;
124903->124904;
124904->124905;
124905->124906;
124906->124907;
124907->124908;
}
124877
124903