digraph G {
subgraph clusterstage_27659 {
label="Stage 27659";
120977 [labelType="html" label="JDBCRDD [120977]<br>cache at <unknown>:0"];
subgraph cluster302572 {
label="WholeStageCodegen (1)";
120978 [labelType="html" label="MapPartitionsRDD [120978]<br>count at <unknown>:0"];
}
subgraph cluster302574 {
label="mapPartitionsInternal";
120979 [labelType="html" label="MapPartitionsRDD [120979]<br>count at <unknown>:0"];
}
subgraph cluster302575 {
label="mapPartitionsInternal";
120980 [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#12295297,supplier_id#12295298,entity_name#12295299,city#12295300,state#12295301,country#12295302,supplier_type#12295303,declaring_supplier_id#12295304,canonical_id#12295305,is_primary#12295306,threshold#12295307,create_date#12295308] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [120980] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster302632 {
label="InMemoryTableScan";
121001 [labelType="html" label="MapPartitionsRDD [121001]<br>count at <unknown>:0"];
121002 [labelType="html" label="MapPartitionsRDD [121002]<br>count at <unknown>:0"];
121003 [labelType="html" label="MapPartitionsRDD [121003]<br>count at <unknown>:0"];
}
subgraph cluster302628 {
label="WholeStageCodegen (1)";
121004 [labelType="html" label="MapPartitionsRDD [121004]<br>count at <unknown>:0"];
}
subgraph cluster302633 {
label="mapPartitionsInternal";
121005 [labelType="html" label="MapPartitionsRDD [121005]<br>count at <unknown>:0"];
}
subgraph cluster302634 {
label="mapPartitionsInternal";
121006 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#12295305)\n +- InMemoryTableScan [brand_context_id#12295297, supplier_id#12295298, canonical_id#12295305, is_primary#12295306, entity_name#12295299, city#12295300, state#12295301, country#12295302, threshold#12295307, create_date#12295308], [isnotnull(canonical_id#12295305)]\n +- InMemoryRelation [brand_context_id#12295297, supplier_id#12295298, entity_name#12295299, city#12295300, state#12295301, country#12295302, supplier_type#12295303, declaring_supplier_id#12295304, canonical_id#12295305, is_primary#12295306, threshold#12295307, create_date#12295308], 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 ... [121006] [Cached]<br>count at <unknown>:0"];
}
}
120977->120978;
120978->120979;
120979->120980;
120980->121001;
121001->121002;
121002->121003;
121003->121004;
121004->121005;
121005->121006;
}
120980
121006