digraph G {
subgraph clusterstage_26807 {
label="Stage 26807";
118030 [labelType="html" label="JDBCRDD [118030]<br>cache at <unknown>:0"];
subgraph cluster295818 {
label="WholeStageCodegen (1)";
118031 [labelType="html" label="MapPartitionsRDD [118031]<br>count at <unknown>:0"];
}
subgraph cluster295820 {
label="mapPartitionsInternal";
118032 [labelType="html" label="MapPartitionsRDD [118032]<br>count at <unknown>:0"];
}
subgraph cluster295821 {
label="mapPartitionsInternal";
118033 [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#12040613,supplier_id#12040614,entity_name#12040615,city#12040616,state#12040617,country#12040618,supplier_type#12040619,declaring_supplier_id#12040620,canonical_id#12040621,is_primary#12040622,threshold#12040623,create_date#12040624] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [118033] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster295878 {
label="InMemoryTableScan";
118054 [labelType="html" label="MapPartitionsRDD [118054]<br>count at <unknown>:0"];
118055 [labelType="html" label="MapPartitionsRDD [118055]<br>count at <unknown>:0"];
118056 [labelType="html" label="MapPartitionsRDD [118056]<br>count at <unknown>:0"];
}
subgraph cluster295874 {
label="WholeStageCodegen (1)";
118057 [labelType="html" label="MapPartitionsRDD [118057]<br>count at <unknown>:0"];
}
subgraph cluster295879 {
label="mapPartitionsInternal";
118058 [labelType="html" label="MapPartitionsRDD [118058]<br>count at <unknown>:0"];
}
subgraph cluster295880 {
label="mapPartitionsInternal";
118059 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#12040621)\n +- InMemoryTableScan [brand_context_id#12040613, supplier_id#12040614, canonical_id#12040621, is_primary#12040622, entity_name#12040615, city#12040616, state#12040617, country#12040618, threshold#12040623, create_date#12040624], [isnotnull(canonical_id#12040621)]\n +- InMemoryRelation [brand_context_id#12040613, supplier_id#12040614, entity_name#12040615, city#12040616, state#12040617, country#12040618, supplier_type#12040619, declaring_supplier_id#12040620, canonical_id#12040621, is_primary#12040622, threshold#12040623, create_date#12040624], 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 ... [118059] [Cached]<br>count at <unknown>:0"];
}
}
118030->118031;
118031->118032;
118032->118033;
118033->118054;
118054->118055;
118055->118056;
118056->118057;
118057->118058;
118058->118059;
}
118033
118059