digraph G {
subgraph clusterstage_27692 {
label="Stage 27692";
121091 [labelType="html" label="JDBCRDD [121091]<br>cache at <unknown>:0"];
subgraph cluster302845 {
label="WholeStageCodegen (1)";
121092 [labelType="html" label="MapPartitionsRDD [121092]<br>count at <unknown>:0"];
}
subgraph cluster302847 {
label="mapPartitionsInternal";
121093 [labelType="html" label="MapPartitionsRDD [121093]<br>count at <unknown>:0"];
}
subgraph cluster302848 {
label="mapPartitionsInternal";
121094 [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#12299740,supplier_id#12299741,entity_name#12299742,city#12299743,state#12299744,country#12299745,supplier_type#12299746,declaring_supplier_id#12299747,canonical_id#12299748,is_primary#12299749,threshold#12299750,create_date#12299751] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [121094] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster302905 {
label="InMemoryTableScan";
121115 [labelType="html" label="MapPartitionsRDD [121115]<br>count at <unknown>:0"];
121116 [labelType="html" label="MapPartitionsRDD [121116]<br>count at <unknown>:0"];
121117 [labelType="html" label="MapPartitionsRDD [121117]<br>count at <unknown>:0"];
}
subgraph cluster302901 {
label="WholeStageCodegen (1)";
121118 [labelType="html" label="MapPartitionsRDD [121118]<br>count at <unknown>:0"];
}
subgraph cluster302906 {
label="mapPartitionsInternal";
121119 [labelType="html" label="MapPartitionsRDD [121119]<br>count at <unknown>:0"];
}
subgraph cluster302907 {
label="mapPartitionsInternal";
121120 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#12299748)\n +- InMemoryTableScan [brand_context_id#12299740, supplier_id#12299741, canonical_id#12299748, is_primary#12299749, entity_name#12299742, city#12299743, state#12299744, country#12299745, threshold#12299750, create_date#12299751], [isnotnull(canonical_id#12299748)]\n +- InMemoryRelation [brand_context_id#12299740, supplier_id#12299741, entity_name#12299742, city#12299743, state#12299744, country#12299745, supplier_type#12299746, declaring_supplier_id#12299747, canonical_id#12299748, is_primary#12299749, threshold#12299750, create_date#12299751], 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 ... [121120] [Cached]<br>count at <unknown>:0"];
}
}
121091->121092;
121092->121093;
121093->121094;
121094->121115;
121115->121116;
121116->121117;
121117->121118;
121118->121119;
121119->121120;
}
121094
121120