digraph G {
subgraph clusterstage_27733 {
label="Stage 27733";
121243 [labelType="html" label="JDBCRDD [121243]<br>cache at <unknown>:0"];
subgraph cluster303209 {
label="WholeStageCodegen (1)";
121244 [labelType="html" label="MapPartitionsRDD [121244]<br>count at <unknown>:0"];
}
subgraph cluster303211 {
label="mapPartitionsInternal";
121245 [labelType="html" label="MapPartitionsRDD [121245]<br>count at <unknown>:0"];
}
subgraph cluster303212 {
label="mapPartitionsInternal";
121246 [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#12305664,supplier_id#12305665,entity_name#12305666,city#12305667,state#12305668,country#12305669,supplier_type#12305670,declaring_supplier_id#12305671,canonical_id#12305672,is_primary#12305673,threshold#12305674,create_date#12305675] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [121246] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster303244 {
label="InMemoryTableScan";
121255 [labelType="html" label="MapPartitionsRDD [121255]<br>count at <unknown>:0"];
121256 [labelType="html" label="MapPartitionsRDD [121256]<br>count at <unknown>:0"];
121257 [labelType="html" label="MapPartitionsRDD [121257]<br>count at <unknown>:0"];
}
subgraph cluster303239 {
label="WholeStageCodegen (1)";
121258 [labelType="html" label="MapPartitionsRDD [121258]<br>count at <unknown>:0"];
}
subgraph cluster303245 {
label="mapPartitionsInternal";
121259 [labelType="html" label="MapPartitionsRDD [121259]<br>count at <unknown>:0"];
}
subgraph cluster303246 {
label="mapPartitionsInternal";
121260 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#12305664, supplier_id#12305665, entity_name#12305666, city#12305667, state#12305668, country#12305669, supplier_type#12305670, declaring_supplier_id#12305671, threshold#12305674, create_date#12305675]\n +- Filter isnull(canonical_id#12305672)\n +- InMemoryTableScan [brand_context_id#12305664, canonical_id#12305672, city#12305667, country#12305669, create_date#12305675, declaring_supplier_id#12305671, entity_name#12305666, state#12305668, supplier_id#12305665, supplier_type#12305670, threshold#12305674], [isnull(canonical_id#12305672)]\n +- InMemoryRelation [brand_context_id#12305664, supplier_id#12305665, entity_name#12305666, city#12305667, state#12305668, country#12305669, supplier_type#12305670, declaring_supplier_id#12305671, canonical_id#12305672, is_primary#12305673, threshold#12305674, create_date#12305675], StorageLevel(disk, memory, deserialized, 1 replicas)\n +- *(1) Scan JDBCRelation((\n SEL... [121260] [Cached]<br>count at <unknown>:0"];
}
}
121243->121244;
121244->121245;
121245->121246;
121246->121255;
121255->121256;
121256->121257;
121257->121258;
121258->121259;
121259->121260;
}
121246
121260