digraph G {
subgraph clusterstage_30035 {
label="Stage 30035";
129189 [labelType="html" label="JDBCRDD [129189]<br>cache at <unknown>:0"];
subgraph cluster321631 {
label="WholeStageCodegen (1)";
129190 [labelType="html" label="MapPartitionsRDD [129190]<br>count at <unknown>:0"];
}
subgraph cluster321633 {
label="mapPartitionsInternal";
129191 [labelType="html" label="MapPartitionsRDD [129191]<br>count at <unknown>:0"];
}
subgraph cluster321634 {
label="mapPartitionsInternal";
129192 [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#12895006,supplier_id#12895007,entity_name#12895008,city#12895009,state#12895010,country#12895011,supplier_type#12895012,declaring_supplier_id#12895013,canonical_id#12895014,is_primary#12895015,threshold#12895016,create_date#12895017] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [129192] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster321691 {
label="InMemoryTableScan";
129213 [labelType="html" label="MapPartitionsRDD [129213]<br>count at <unknown>:0"];
129214 [labelType="html" label="MapPartitionsRDD [129214]<br>count at <unknown>:0"];
129215 [labelType="html" label="MapPartitionsRDD [129215]<br>count at <unknown>:0"];
}
subgraph cluster321687 {
label="WholeStageCodegen (1)";
129216 [labelType="html" label="MapPartitionsRDD [129216]<br>count at <unknown>:0"];
}
subgraph cluster321692 {
label="mapPartitionsInternal";
129217 [labelType="html" label="MapPartitionsRDD [129217]<br>count at <unknown>:0"];
}
subgraph cluster321693 {
label="mapPartitionsInternal";
129218 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#12895014)\n +- InMemoryTableScan [brand_context_id#12895006, supplier_id#12895007, canonical_id#12895014, is_primary#12895015, entity_name#12895008, city#12895009, state#12895010, country#12895011, threshold#12895016, create_date#12895017], [isnotnull(canonical_id#12895014)]\n +- InMemoryRelation [brand_context_id#12895006, supplier_id#12895007, entity_name#12895008, city#12895009, state#12895010, country#12895011, supplier_type#12895012, declaring_supplier_id#12895013, canonical_id#12895014, is_primary#12895015, threshold#12895016, create_date#12895017], 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 ... [129218] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster321699 {
label="InMemoryTableScan";
129219 [labelType="html" label="MapPartitionsRDD [129219]<br>count at <unknown>:0"];
129220 [labelType="html" label="MapPartitionsRDD [129220]<br>count at <unknown>:0"];
129221 [labelType="html" label="MapPartitionsRDD [129221]<br>count at <unknown>:0"];
}
subgraph cluster321695 {
label="WholeStageCodegen (1)";
129222 [labelType="html" label="MapPartitionsRDD [129222]<br>count at <unknown>:0"];
}
subgraph cluster321694 {
label="Exchange";
129223 [labelType="html" label="MapPartitionsRDD [129223]<br>count at <unknown>:0"];
}
}
129189->129190;
129190->129191;
129191->129192;
129192->129213;
129213->129214;
129214->129215;
129215->129216;
129216->129217;
129217->129218;
129218->129219;
129219->129220;
129220->129221;
129221->129222;
129222->129223;
}
129192
129218