digraph G {
subgraph clusterstage_812 {
label="Stage 812";
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 cluster6425 {
label="InMemoryTableScan";
2807 [labelType="html" label="MapPartitionsRDD [2807]<br>count at <unknown>:0"];
2808 [labelType="html" label="MapPartitionsRDD [2808]<br>count at <unknown>:0"];
2809 [labelType="html" label="MapPartitionsRDD [2809]<br>count at <unknown>:0"];
}
subgraph cluster6420 {
label="WholeStageCodegen (1)";
2810 [labelType="html" label="MapPartitionsRDD [2810]<br>count at <unknown>:0"];
}
subgraph cluster6426 {
label="mapPartitionsInternal";
2811 [labelType="html" label="MapPartitionsRDD [2811]<br>count at <unknown>:0"];
}
subgraph cluster6427 {
label="mapPartitionsInternal";
2812 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#248760, supplier_id#248761, entity_name#248762, city#248763, state#248764, country#248765, supplier_type#248766, declaring_supplier_id#248767, threshold#248770, create_date#248771]\n +- Filter isnull(canonical_id#248768)\n +- InMemoryTableScan [brand_context_id#248760, canonical_id#248768, city#248763, country#248765, create_date#248771, declaring_supplier_id#248767, entity_name#248762, state#248764, supplier_id#248761, supplier_type#248766, threshold#248770], [isnull(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.sup... [2812] [Cached]<br>count at <unknown>:0"];
}
}
2795->2796;
2796->2797;
2797->2798;
2798->2807;
2807->2808;
2808->2809;
2809->2810;
2810->2811;
2811->2812;
}
2798
2812