digraph G {
subgraph clusterstage_40735 {
label="Stage 40735";
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 cluster413735 {
label="InMemoryTableScan";
173700 [labelType="html" label="MapPartitionsRDD [173700]<br>count at <unknown>:0"];
173701 [labelType="html" label="MapPartitionsRDD [173701]<br>count at <unknown>:0"];
173702 [labelType="html" label="MapPartitionsRDD [173702]<br>count at <unknown>:0"];
}
subgraph cluster413731 {
label="WholeStageCodegen (1)";
173703 [labelType="html" label="MapPartitionsRDD [173703]<br>count at <unknown>:0"];
}
subgraph cluster413736 {
label="mapPartitionsInternal";
173704 [labelType="html" label="MapPartitionsRDD [173704]<br>count at <unknown>:0"];
}
subgraph cluster413737 {
label="mapPartitionsInternal";
173705 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#20662003)\n +- InMemoryTableScan [brand_context_id#20661995, supplier_id#20661996, canonical_id#20662003, is_primary#20662004, entity_name#20661997, city#20661998, state#20661999, country#20662000, threshold#20662005, create_date#20662006], [isnotnull(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 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 ... [173705] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster413743 {
label="InMemoryTableScan";
173706 [labelType="html" label="MapPartitionsRDD [173706]<br>count at <unknown>:0"];
173707 [labelType="html" label="MapPartitionsRDD [173707]<br>count at <unknown>:0"];
173708 [labelType="html" label="MapPartitionsRDD [173708]<br>count at <unknown>:0"];
}
subgraph cluster413739 {
label="WholeStageCodegen (1)";
173709 [labelType="html" label="MapPartitionsRDD [173709]<br>count at <unknown>:0"];
}
subgraph cluster413738 {
label="Exchange";
173710 [labelType="html" label="MapPartitionsRDD [173710]<br>count at <unknown>:0"];
}
}
173676->173677;
173677->173678;
173678->173679;
173679->173700;
173700->173701;
173701->173702;
173702->173703;
173703->173704;
173704->173705;
173705->173706;
173706->173707;
173707->173708;
173708->173709;
173709->173710;
}
173679
173705