digraph G {
subgraph clusterstage_44078 {
label="Stage 44078";
191329 [labelType="html" label="JDBCRDD [191329]<br>cache at <unknown>:0"];
subgraph cluster451153 {
label="WholeStageCodegen (1)";
191330 [labelType="html" label="MapPartitionsRDD [191330]<br>count at <unknown>:0"];
}
subgraph cluster451155 {
label="mapPartitionsInternal";
191331 [labelType="html" label="MapPartitionsRDD [191331]<br>count at <unknown>:0"];
}
subgraph cluster451156 {
label="mapPartitionsInternal";
191332 [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#17299697,supplier_id#17299698,entity_name#17299699,city#17299700,state#17299701,country#17299702,supplier_type#17299703,declaring_supplier_id#17299704,canonical_id#17299705,is_primary#17299706,threshold#17299707,create_date#17299708] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [191332] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster451213 {
label="InMemoryTableScan";
191353 [labelType="html" label="MapPartitionsRDD [191353]<br>count at <unknown>:0"];
191354 [labelType="html" label="MapPartitionsRDD [191354]<br>count at <unknown>:0"];
191355 [labelType="html" label="MapPartitionsRDD [191355]<br>count at <unknown>:0"];
}
subgraph cluster451209 {
label="WholeStageCodegen (1)";
191356 [labelType="html" label="MapPartitionsRDD [191356]<br>count at <unknown>:0"];
}
subgraph cluster451214 {
label="mapPartitionsInternal";
191357 [labelType="html" label="MapPartitionsRDD [191357]<br>count at <unknown>:0"];
}
subgraph cluster451215 {
label="mapPartitionsInternal";
191358 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#17299705)\n +- InMemoryTableScan [brand_context_id#17299697, supplier_id#17299698, canonical_id#17299705, is_primary#17299706, entity_name#17299699, city#17299700, state#17299701, country#17299702, threshold#17299707, create_date#17299708], [isnotnull(canonical_id#17299705)]\n +- InMemoryRelation [brand_context_id#17299697, supplier_id#17299698, entity_name#17299699, city#17299700, state#17299701, country#17299702, supplier_type#17299703, declaring_supplier_id#17299704, canonical_id#17299705, is_primary#17299706, threshold#17299707, create_date#17299708], 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 ... [191358] [Cached]<br>count at <unknown>:0"];
}
}
191329->191330;
191330->191331;
191331->191332;
191332->191353;
191353->191354;
191354->191355;
191355->191356;
191356->191357;
191357->191358;
}
191332
191358