digraph G {
subgraph clusterstage_40731 {
label="Stage 40731";
173676 [labelType="html" label="JDBCRDD [173676]<br>cache at <unknown>:0"];
subgraph cluster413675 {
label="WholeStageCodegen (1)";
173677 [labelType="html" label="MapPartitionsRDD [173677]<br>count at <unknown>:0"];
}
subgraph cluster413677 {
label="mapPartitionsInternal";
173678 [labelType="html" label="MapPartitionsRDD [173678]<br>count at <unknown>:0"];
}
subgraph cluster413678 {
label="mapPartitionsInternal";
173679 [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#20661995,supplier_id#20661996,entity_name#20661997,city#20661998,state#20661999,country#20662000,supplier_type#20662001,declaring_supplier_id#20662002,canonical_id#20662003,is_primary#20662004,threshold#20662005,create_date#20662006] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [173679] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster413710 {
label="InMemoryTableScan";
173688 [labelType="html" label="MapPartitionsRDD [173688]<br>count at <unknown>:0"];
173689 [labelType="html" label="MapPartitionsRDD [173689]<br>count at <unknown>:0"];
173690 [labelType="html" label="MapPartitionsRDD [173690]<br>count at <unknown>:0"];
}
subgraph cluster413705 {
label="WholeStageCodegen (1)";
173691 [labelType="html" label="MapPartitionsRDD [173691]<br>count at <unknown>:0"];
}
subgraph cluster413711 {
label="mapPartitionsInternal";
173692 [labelType="html" label="MapPartitionsRDD [173692]<br>count at <unknown>:0"];
}
subgraph cluster413712 {
label="mapPartitionsInternal";
173693 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#20661995, supplier_id#20661996, entity_name#20661997, city#20661998, state#20661999, country#20662000, supplier_type#20662001, declaring_supplier_id#20662002, threshold#20662005, create_date#20662006]\n +- Filter isnull(canonical_id#20662003)\n +- InMemoryTableScan [brand_context_id#20661995, canonical_id#20662003, city#20661998, country#20662000, create_date#20662006, declaring_supplier_id#20662002, entity_name#20661997, state#20661999, supplier_id#20661996, supplier_type#20662001, threshold#20662005], [isnull(canonical_id#20662003)]\n +- InMemoryRelation [brand_context_id#20661995, supplier_id#20661996, entity_name#20661997, city#20661998, state#20661999, country#20662000, supplier_type#20662001, declaring_supplier_id#20662002, canonical_id#20662003, is_primary#20662004, threshold#20662005, create_date#20662006], StorageLevel(disk, memory, deserialized, 1 replicas)\n +- *(1) Scan JDBCRelation((\n SEL... [173693] [Cached]<br>count at <unknown>:0"];
}
}
173676->173677;
173677->173678;
173678->173679;
173679->173688;
173688->173689;
173689->173690;
173690->173691;
173691->173692;
173692->173693;
}
173679
173693