digraph G {
subgraph clusterstage_26826 {
label="Stage 26826";
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 cluster296035 {
label="InMemoryTableScan";
118118 [labelType="html" label="MapPartitionsRDD [118118]<br>count at <unknown>:0"];
118119 [labelType="html" label="MapPartitionsRDD [118119]<br>count at <unknown>:0"];
118120 [labelType="html" label="MapPartitionsRDD [118120]<br>count at <unknown>:0"];
}
subgraph cluster296030 {
label="WholeStageCodegen (1)";
118121 [labelType="html" label="MapPartitionsRDD [118121]<br>count at <unknown>:0"];
}
subgraph cluster296036 {
label="mapPartitionsInternal";
118122 [labelType="html" label="MapPartitionsRDD [118122]<br>count at <unknown>:0"];
}
subgraph cluster296037 {
label="mapPartitionsInternal";
118123 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#12043575, supplier_id#12043576, entity_name#12043577, city#12043578, state#12043579, country#12043580, supplier_type#12043581, declaring_supplier_id#12043582, threshold#12043585, create_date#12043586]\n +- Filter isnull(canonical_id#12043583)\n +- InMemoryTableScan [brand_context_id#12043575, canonical_id#12043583, city#12043578, country#12043580, create_date#12043586, declaring_supplier_id#12043582, entity_name#12043577, state#12043579, supplier_id#12043576, supplier_type#12043581, threshold#12043585], [isnull(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 SEL... [118123] [Cached]<br>count at <unknown>:0"];
}
}
118106->118107;
118107->118108;
118108->118109;
118109->118118;
118118->118119;
118119->118120;
118120->118121;
118121->118122;
118122->118123;
}
118109
118123