digraph G {
subgraph clusterstage_29 {
label="Stage 29";
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 cluster242 {
label="InMemoryTableScan";
100 [labelType="html" label="MapPartitionsRDD [100]<br>count at <unknown>:0"];
101 [labelType="html" label="MapPartitionsRDD [101]<br>count at <unknown>:0"];
102 [labelType="html" label="MapPartitionsRDD [102]<br>count at <unknown>:0"];
}
subgraph cluster238 {
label="WholeStageCodegen (1)";
103 [labelType="html" label="MapPartitionsRDD [103]<br>count at <unknown>:0"];
}
subgraph cluster243 {
label="mapPartitionsInternal";
104 [labelType="html" label="MapPartitionsRDD [104]<br>count at <unknown>:0"];
}
subgraph cluster244 {
label="mapPartitionsInternal";
105 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#2970)\n +- InMemoryTableScan [brand_context_id#2962, supplier_id#2963, canonical_id#2970, is_primary#2971, entity_name#2964, city#2965, state#2966, country#2967, threshold#2972, create_date#2973], [isnotnull(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 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) A... [105] [Cached]<br>count at <unknown>:0"];
}
}
76->77;
77->78;
78->79;
79->100;
100->101;
101->102;
102->103;
103->104;
104->105;
}
79
105