digraph G {
subgraph clusterstage_26829 {
label="Stage 26829";
118106 [labelType="html" label="JDBCRDD [118106]<br>cache at <unknown>:0"];
subgraph cluster296000 {
label="WholeStageCodegen (1)";
118107 [labelType="html" label="MapPartitionsRDD [118107]<br>count at <unknown>:0"];
}
subgraph cluster296002 {
label="mapPartitionsInternal";
118108 [labelType="html" label="MapPartitionsRDD [118108]<br>count at <unknown>:0"];
}
subgraph cluster296003 {
label="mapPartitionsInternal";
118109 [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#12043575,supplier_id#12043576,entity_name#12043577,city#12043578,state#12043579,country#12043580,supplier_type#12043581,declaring_supplier_id#12043582,canonical_id#12043583,is_primary#12043584,threshold#12043585,create_date#12043586] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [118109] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster296060 {
label="InMemoryTableScan";
118130 [labelType="html" label="MapPartitionsRDD [118130]<br>count at <unknown>:0"];
118131 [labelType="html" label="MapPartitionsRDD [118131]<br>count at <unknown>:0"];
118132 [labelType="html" label="MapPartitionsRDD [118132]<br>count at <unknown>:0"];
}
subgraph cluster296056 {
label="WholeStageCodegen (1)";
118133 [labelType="html" label="MapPartitionsRDD [118133]<br>count at <unknown>:0"];
}
subgraph cluster296061 {
label="mapPartitionsInternal";
118134 [labelType="html" label="MapPartitionsRDD [118134]<br>count at <unknown>:0"];
}
subgraph cluster296062 {
label="mapPartitionsInternal";
118135 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#12043583)\n +- InMemoryTableScan [brand_context_id#12043575, supplier_id#12043576, canonical_id#12043583, is_primary#12043584, entity_name#12043577, city#12043578, state#12043579, country#12043580, threshold#12043585, create_date#12043586], [isnotnull(canonical_id#12043583)]\n +- InMemoryRelation [brand_context_id#12043575, supplier_id#12043576, entity_name#12043577, city#12043578, state#12043579, country#12043580, supplier_type#12043581, declaring_supplier_id#12043582, canonical_id#12043583, is_primary#12043584, threshold#12043585, create_date#12043586], 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 ... [118135] [Cached]<br>count at <unknown>:0"];
}
}
118106->118107;
118107->118108;
118108->118109;
118109->118130;
118130->118131;
118131->118132;
118132->118133;
118133->118134;
118134->118135;
}
118109
118135