digraph G {
subgraph clusterstage_28819 {
label="Stage 28819";
124988 [labelType="html" label="JDBCRDD [124988]<br>cache at <unknown>:0"];
subgraph cluster311874 {
label="WholeStageCodegen (1)";
124989 [labelType="html" label="MapPartitionsRDD [124989]<br>count at <unknown>:0"];
}
subgraph cluster311876 {
label="mapPartitionsInternal";
124990 [labelType="html" label="MapPartitionsRDD [124990]<br>count at <unknown>:0"];
}
subgraph cluster311877 {
label="mapPartitionsInternal";
124991 [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#12591449,supplier_id#12591450,entity_name#12591451,city#12591452,state#12591453,country#12591454,supplier_type#12591455,declaring_supplier_id#12591456,canonical_id#12591457,is_primary#12591458,threshold#12591459,create_date#12591460] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [124991] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster311934 {
label="InMemoryTableScan";
125012 [labelType="html" label="MapPartitionsRDD [125012]<br>count at <unknown>:0"];
125013 [labelType="html" label="MapPartitionsRDD [125013]<br>count at <unknown>:0"];
125014 [labelType="html" label="MapPartitionsRDD [125014]<br>count at <unknown>:0"];
}
subgraph cluster311930 {
label="WholeStageCodegen (1)";
125015 [labelType="html" label="MapPartitionsRDD [125015]<br>count at <unknown>:0"];
}
subgraph cluster311935 {
label="mapPartitionsInternal";
125016 [labelType="html" label="MapPartitionsRDD [125016]<br>count at <unknown>:0"];
}
subgraph cluster311936 {
label="mapPartitionsInternal";
125017 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#12591457)\n +- InMemoryTableScan [brand_context_id#12591449, supplier_id#12591450, canonical_id#12591457, is_primary#12591458, entity_name#12591451, city#12591452, state#12591453, country#12591454, threshold#12591459, create_date#12591460], [isnotnull(canonical_id#12591457)]\n +- InMemoryRelation [brand_context_id#12591449, supplier_id#12591450, entity_name#12591451, city#12591452, state#12591453, country#12591454, supplier_type#12591455, declaring_supplier_id#12591456, canonical_id#12591457, is_primary#12591458, threshold#12591459, create_date#12591460], 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 ... [125017] [Cached]<br>count at <unknown>:0"];
}
}
124988->124989;
124989->124990;
124990->124991;
124991->125012;
125012->125013;
125013->125014;
125014->125015;
125015->125016;
125016->125017;
}
124991
125017