digraph G {
subgraph clusterstage_26 {
label="Stage 26";
76 [labelType="html" label="JDBCRDD [76]<br>cache at <unknown>:0"];
subgraph cluster182 {
label="WholeStageCodegen (1)";
77 [labelType="html" label="MapPartitionsRDD [77]<br>count at <unknown>:0"];
}
subgraph cluster184 {
label="mapPartitionsInternal";
78 [labelType="html" label="MapPartitionsRDD [78]<br>count at <unknown>:0"];
}
subgraph cluster185 {
label="mapPartitionsInternal";
79 [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#2962,supplier_id#2963,entity_name#2964,city#2965,state#2966,country#2967,supplier_type#2968,declaring_supplier_id#2969,canonical_id#2970,is_primary#2971,threshold#2972,create_date#2973] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [79] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster217 {
label="InMemoryTableScan";
88 [labelType="html" label="MapPartitionsRDD [88]<br>count at <unknown>:0"];
89 [labelType="html" label="MapPartitionsRDD [89]<br>count at <unknown>:0"];
90 [labelType="html" label="MapPartitionsRDD [90]<br>count at <unknown>:0"];
}
subgraph cluster212 {
label="WholeStageCodegen (1)";
91 [labelType="html" label="MapPartitionsRDD [91]<br>count at <unknown>:0"];
}
subgraph cluster218 {
label="mapPartitionsInternal";
92 [labelType="html" label="MapPartitionsRDD [92]<br>count at <unknown>:0"];
}
subgraph cluster219 {
label="mapPartitionsInternal";
93 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#2962, supplier_id#2963, entity_name#2964, city#2965, state#2966, country#2967, supplier_type#2968, declaring_supplier_id#2969, threshold#2972, create_date#2973]\n +- Filter isnull(canonical_id#2970)\n +- InMemoryTableScan [brand_context_id#2962, canonical_id#2970, city#2965, country#2967, create_date#2973, declaring_supplier_id#2969, entity_name#2964, state#2966, supplier_id#2963, supplier_type#2968, threshold#2972], [isnull(canonical_id#2970)]\n +- InMemoryRelation [brand_context_id#2962, supplier_id#2963, entity_name#2964, city#2965, state#2966, country#2967, supplier_type#2968, declaring_supplier_id#2969, canonical_id#2970, is_primary#2971, threshold#2972, create_date#2973], 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 ... [93] [Cached]<br>count at <unknown>:0"];
}
}
76->77;
77->78;
78->79;
79->88;
88->89;
89->90;
90->91;
91->92;
92->93;
}
79
93