digraph G {
subgraph clusterstage_28776 {
label="Stage 28776";
124836 [labelType="html" label="JDBCRDD [124836]<br>cache at <unknown>:0"];
subgraph cluster311510 {
label="WholeStageCodegen (1)";
124837 [labelType="html" label="MapPartitionsRDD [124837]<br>count at <unknown>:0"];
}
subgraph cluster311512 {
label="mapPartitionsInternal";
124838 [labelType="html" label="MapPartitionsRDD [124838]<br>count at <unknown>:0"];
}
subgraph cluster311513 {
label="mapPartitionsInternal";
124839 [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#12585525,supplier_id#12585526,entity_name#12585527,city#12585528,state#12585529,country#12585530,supplier_type#12585531,declaring_supplier_id#12585532,canonical_id#12585533,is_primary#12585534,threshold#12585535,create_date#12585536] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [124839] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster311570 {
label="InMemoryTableScan";
124860 [labelType="html" label="MapPartitionsRDD [124860]<br>count at <unknown>:0"];
124861 [labelType="html" label="MapPartitionsRDD [124861]<br>count at <unknown>:0"];
124862 [labelType="html" label="MapPartitionsRDD [124862]<br>count at <unknown>:0"];
}
subgraph cluster311566 {
label="WholeStageCodegen (1)";
124863 [labelType="html" label="MapPartitionsRDD [124863]<br>count at <unknown>:0"];
}
subgraph cluster311571 {
label="mapPartitionsInternal";
124864 [labelType="html" label="MapPartitionsRDD [124864]<br>count at <unknown>:0"];
}
subgraph cluster311572 {
label="mapPartitionsInternal";
124865 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#12585533)\n +- InMemoryTableScan [brand_context_id#12585525, supplier_id#12585526, canonical_id#12585533, is_primary#12585534, entity_name#12585527, city#12585528, state#12585529, country#12585530, threshold#12585535, create_date#12585536], [isnotnull(canonical_id#12585533)]\n +- InMemoryRelation [brand_context_id#12585525, supplier_id#12585526, entity_name#12585527, city#12585528, state#12585529, country#12585530, supplier_type#12585531, declaring_supplier_id#12585532, canonical_id#12585533, is_primary#12585534, threshold#12585535, create_date#12585536], 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 ... [124865] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster311578 {
label="InMemoryTableScan";
124866 [labelType="html" label="MapPartitionsRDD [124866]<br>count at <unknown>:0"];
124867 [labelType="html" label="MapPartitionsRDD [124867]<br>count at <unknown>:0"];
124868 [labelType="html" label="MapPartitionsRDD [124868]<br>count at <unknown>:0"];
}
subgraph cluster311574 {
label="WholeStageCodegen (1)";
124869 [labelType="html" label="MapPartitionsRDD [124869]<br>count at <unknown>:0"];
}
subgraph cluster311573 {
label="Exchange";
124870 [labelType="html" label="MapPartitionsRDD [124870]<br>count at <unknown>:0"];
}
}
124836->124837;
124837->124838;
124838->124839;
124839->124860;
124860->124861;
124861->124862;
124862->124863;
124863->124864;
124864->124865;
124865->124866;
124866->124867;
124867->124868;
124868->124869;
124869->124870;
}
124839
124865