digraph G {
subgraph clusterstage_3352 {
label="Stage 3352";
11902 [labelType="html" label="JDBCRDD [11902]<br>cache at <unknown>:0"];
subgraph cluster27141 {
label="WholeStageCodegen (1)";
11903 [labelType="html" label="MapPartitionsRDD [11903]<br>count at <unknown>:0"];
}
subgraph cluster27143 {
label="mapPartitionsInternal";
11904 [labelType="html" label="MapPartitionsRDD [11904]<br>count at <unknown>:0"];
}
subgraph cluster27144 {
label="mapPartitionsInternal";
11905 [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#1066089,supplier_id#1066090,entity_name#1066091,city#1066092,state#1066093,country#1066094,supplier_type#1066095,declaring_supplier_id#1066096,canonical_id#1066097,is_primary#1066098,threshold#1066099,create_date#1066100] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [11905] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster27201 {
label="InMemoryTableScan";
11926 [labelType="html" label="MapPartitionsRDD [11926]<br>count at <unknown>:0"];
11927 [labelType="html" label="MapPartitionsRDD [11927]<br>count at <unknown>:0"];
11928 [labelType="html" label="MapPartitionsRDD [11928]<br>count at <unknown>:0"];
}
subgraph cluster27197 {
label="WholeStageCodegen (1)";
11929 [labelType="html" label="MapPartitionsRDD [11929]<br>count at <unknown>:0"];
}
subgraph cluster27202 {
label="mapPartitionsInternal";
11930 [labelType="html" label="MapPartitionsRDD [11930]<br>count at <unknown>:0"];
}
subgraph cluster27203 {
label="mapPartitionsInternal";
11931 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#1066097)\n +- InMemoryTableScan [brand_context_id#1066089, supplier_id#1066090, canonical_id#1066097, is_primary#1066098, entity_name#1066091, city#1066092, state#1066093, country#1066094, threshold#1066099, create_date#1066100], [isnotnull(canonical_id#1066097)]\n +- InMemoryRelation [brand_context_id#1066089, supplier_id#1066090, entity_name#1066091, city#1066092, state#1066093, country#1066094, supplier_type#1066095, declaring_supplier_id#1066096, canonical_id#1066097, is_primary#1066098, threshold#1066099, create_date#1066100], 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 ... [11931] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster27209 {
label="InMemoryTableScan";
11932 [labelType="html" label="MapPartitionsRDD [11932]<br>count at <unknown>:0"];
11933 [labelType="html" label="MapPartitionsRDD [11933]<br>count at <unknown>:0"];
11934 [labelType="html" label="MapPartitionsRDD [11934]<br>count at <unknown>:0"];
}
subgraph cluster27205 {
label="WholeStageCodegen (1)";
11935 [labelType="html" label="MapPartitionsRDD [11935]<br>count at <unknown>:0"];
}
subgraph cluster27204 {
label="Exchange";
11936 [labelType="html" label="MapPartitionsRDD [11936]<br>count at <unknown>:0"];
}
}
11902->11903;
11903->11904;
11904->11905;
11905->11926;
11926->11927;
11927->11928;
11928->11929;
11929->11930;
11930->11931;
11931->11932;
11932->11933;
11933->11934;
11934->11935;
11935->11936;
}
11905
11931