digraph G {
subgraph clusterstage_36192 {
label="Stage 36192";
157222 [labelType="html" label="JDBCRDD [157222]<br>cache at <unknown>:0"];
subgraph cluster379135 {
label="WholeStageCodegen (1)";
157223 [labelType="html" label="MapPartitionsRDD [157223]<br>count at <unknown>:0"];
}
subgraph cluster379137 {
label="mapPartitionsInternal";
157224 [labelType="html" label="MapPartitionsRDD [157224]<br>count at <unknown>:0"];
}
subgraph cluster379138 {
label="mapPartitionsInternal";
157225 [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#14889536,supplier_id#14889537,entity_name#14889538,city#14889539,state#14889540,country#14889541,supplier_type#14889542,declaring_supplier_id#14889543,canonical_id#14889544,is_primary#14889545,threshold#14889546,create_date#14889547] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [157225] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster379195 {
label="InMemoryTableScan";
157246 [labelType="html" label="MapPartitionsRDD [157246]<br>count at <unknown>:0"];
157247 [labelType="html" label="MapPartitionsRDD [157247]<br>count at <unknown>:0"];
157248 [labelType="html" label="MapPartitionsRDD [157248]<br>count at <unknown>:0"];
}
subgraph cluster379191 {
label="WholeStageCodegen (1)";
157249 [labelType="html" label="MapPartitionsRDD [157249]<br>count at <unknown>:0"];
}
subgraph cluster379196 {
label="mapPartitionsInternal";
157250 [labelType="html" label="MapPartitionsRDD [157250]<br>count at <unknown>:0"];
}
subgraph cluster379197 {
label="mapPartitionsInternal";
157251 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#14889544)\n +- InMemoryTableScan [brand_context_id#14889536, supplier_id#14889537, canonical_id#14889544, is_primary#14889545, entity_name#14889538, city#14889539, state#14889540, country#14889541, threshold#14889546, create_date#14889547], [isnotnull(canonical_id#14889544)]\n +- InMemoryRelation [brand_context_id#14889536, supplier_id#14889537, entity_name#14889538, city#14889539, state#14889540, country#14889541, supplier_type#14889542, declaring_supplier_id#14889543, canonical_id#14889544, is_primary#14889545, threshold#14889546, create_date#14889547], 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 ... [157251] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster379203 {
label="InMemoryTableScan";
157252 [labelType="html" label="MapPartitionsRDD [157252]<br>count at <unknown>:0"];
157253 [labelType="html" label="MapPartitionsRDD [157253]<br>count at <unknown>:0"];
157254 [labelType="html" label="MapPartitionsRDD [157254]<br>count at <unknown>:0"];
}
subgraph cluster379199 {
label="WholeStageCodegen (1)";
157255 [labelType="html" label="MapPartitionsRDD [157255]<br>count at <unknown>:0"];
}
subgraph cluster379198 {
label="Exchange";
157256 [labelType="html" label="MapPartitionsRDD [157256]<br>count at <unknown>:0"];
}
}
157222->157223;
157223->157224;
157224->157225;
157225->157246;
157246->157247;
157247->157248;
157248->157249;
157249->157250;
157250->157251;
157251->157252;
157252->157253;
157253->157254;
157254->157255;
157255->157256;
}
157225
157251