digraph G {
subgraph clusterstage_816 {
label="Stage 816";
2795 [labelType="html" label="JDBCRDD [2795]<br>cache at <unknown>:0"];
subgraph cluster6390 {
label="WholeStageCodegen (1)";
2796 [labelType="html" label="MapPartitionsRDD [2796]<br>count at <unknown>:0"];
}
subgraph cluster6392 {
label="mapPartitionsInternal";
2797 [labelType="html" label="MapPartitionsRDD [2797]<br>count at <unknown>:0"];
}
subgraph cluster6393 {
label="mapPartitionsInternal";
2798 [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#248760,supplier_id#248761,entity_name#248762,city#248763,state#248764,country#248765,supplier_type#248766,declaring_supplier_id#248767,canonical_id#248768,is_primary#248769,threshold#248770,create_date#248771] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [2798] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster6450 {
label="InMemoryTableScan";
2819 [labelType="html" label="MapPartitionsRDD [2819]<br>count at <unknown>:0"];
2820 [labelType="html" label="MapPartitionsRDD [2820]<br>count at <unknown>:0"];
2821 [labelType="html" label="MapPartitionsRDD [2821]<br>count at <unknown>:0"];
}
subgraph cluster6446 {
label="WholeStageCodegen (1)";
2822 [labelType="html" label="MapPartitionsRDD [2822]<br>count at <unknown>:0"];
}
subgraph cluster6451 {
label="mapPartitionsInternal";
2823 [labelType="html" label="MapPartitionsRDD [2823]<br>count at <unknown>:0"];
}
subgraph cluster6452 {
label="mapPartitionsInternal";
2824 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#248768)\n +- InMemoryTableScan [brand_context_id#248760, supplier_id#248761, canonical_id#248768, is_primary#248769, entity_name#248762, city#248763, state#248764, country#248765, threshold#248770, create_date#248771], [isnotnull(canonical_id#248768)]\n +- InMemoryRelation [brand_context_id#248760, supplier_id#248761, entity_name#248762, city#248763, state#248764, country#248765, supplier_type#248766, declaring_supplier_id#248767, canonical_id#248768, is_primary#248769, threshold#248770, create_date#248771], 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_prima... [2824] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster6458 {
label="InMemoryTableScan";
2825 [labelType="html" label="MapPartitionsRDD [2825]<br>count at <unknown>:0"];
2826 [labelType="html" label="MapPartitionsRDD [2826]<br>count at <unknown>:0"];
2827 [labelType="html" label="MapPartitionsRDD [2827]<br>count at <unknown>:0"];
}
subgraph cluster6454 {
label="WholeStageCodegen (1)";
2828 [labelType="html" label="MapPartitionsRDD [2828]<br>count at <unknown>:0"];
}
subgraph cluster6453 {
label="Exchange";
2829 [labelType="html" label="MapPartitionsRDD [2829]<br>count at <unknown>:0"];
}
}
2795->2796;
2796->2797;
2797->2798;
2798->2819;
2819->2820;
2820->2821;
2821->2822;
2822->2823;
2823->2824;
2824->2825;
2825->2826;
2826->2827;
2827->2828;
2828->2829;
}
2798
2824