digraph G {
subgraph clusterstage_28742 {
label="Stage 28742";
124722 [labelType="html" label="JDBCRDD [124722]<br>cache at <unknown>:0"];
subgraph cluster311237 {
label="WholeStageCodegen (1)";
124723 [labelType="html" label="MapPartitionsRDD [124723]<br>count at <unknown>:0"];
}
subgraph cluster311239 {
label="mapPartitionsInternal";
124724 [labelType="html" label="MapPartitionsRDD [124724]<br>count at <unknown>:0"];
}
subgraph cluster311240 {
label="mapPartitionsInternal";
124725 [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#12581082,supplier_id#12581083,entity_name#12581084,city#12581085,state#12581086,country#12581087,supplier_type#12581088,declaring_supplier_id#12581089,canonical_id#12581090,is_primary#12581091,threshold#12581092,create_date#12581093] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [124725] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster311297 {
label="InMemoryTableScan";
124746 [labelType="html" label="MapPartitionsRDD [124746]<br>count at <unknown>:0"];
124747 [labelType="html" label="MapPartitionsRDD [124747]<br>count at <unknown>:0"];
124748 [labelType="html" label="MapPartitionsRDD [124748]<br>count at <unknown>:0"];
}
subgraph cluster311293 {
label="WholeStageCodegen (1)";
124749 [labelType="html" label="MapPartitionsRDD [124749]<br>count at <unknown>:0"];
}
subgraph cluster311298 {
label="mapPartitionsInternal";
124750 [labelType="html" label="MapPartitionsRDD [124750]<br>count at <unknown>:0"];
}
subgraph cluster311299 {
label="mapPartitionsInternal";
124751 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#12581090)\n +- InMemoryTableScan [brand_context_id#12581082, supplier_id#12581083, canonical_id#12581090, is_primary#12581091, entity_name#12581084, city#12581085, state#12581086, country#12581087, threshold#12581092, create_date#12581093], [isnotnull(canonical_id#12581090)]\n +- InMemoryRelation [brand_context_id#12581082, supplier_id#12581083, entity_name#12581084, city#12581085, state#12581086, country#12581087, supplier_type#12581088, declaring_supplier_id#12581089, canonical_id#12581090, is_primary#12581091, threshold#12581092, create_date#12581093], 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 ... [124751] [Cached]<br>count at <unknown>:0"];
}
}
124722->124723;
124723->124724;
124724->124725;
124725->124746;
124746->124747;
124747->124748;
124748->124749;
124749->124750;
124750->124751;
}
124725
124751