digraph G {
subgraph clusterstage_30156 {
label="Stage 30156";
129711 [labelType="html" label="JDBCRDD [129711]<br>cache at <unknown>:0"];
subgraph cluster322727 {
label="WholeStageCodegen (1)";
129712 [labelType="html" label="MapPartitionsRDD [129712]<br>count at <unknown>:0"];
}
subgraph cluster322729 {
label="mapPartitionsInternal";
129713 [labelType="html" label="MapPartitionsRDD [129713]<br>count at <unknown>:0"];
}
subgraph cluster322730 {
label="mapPartitionsInternal";
129714 [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#12972378,supplier_id#12972379,entity_name#12972380,city#12972381,state#12972382,country#12972383,supplier_type#12972384,declaring_supplier_id#12972385,canonical_id#12972386,is_primary#12972387,threshold#12972388,create_date#12972389] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [129714] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster322787 {
label="InMemoryTableScan";
129735 [labelType="html" label="MapPartitionsRDD [129735]<br>count at <unknown>:0"];
129736 [labelType="html" label="MapPartitionsRDD [129736]<br>count at <unknown>:0"];
129737 [labelType="html" label="MapPartitionsRDD [129737]<br>count at <unknown>:0"];
}
subgraph cluster322783 {
label="WholeStageCodegen (1)";
129738 [labelType="html" label="MapPartitionsRDD [129738]<br>count at <unknown>:0"];
}
subgraph cluster322788 {
label="mapPartitionsInternal";
129739 [labelType="html" label="MapPartitionsRDD [129739]<br>count at <unknown>:0"];
}
subgraph cluster322789 {
label="mapPartitionsInternal";
129740 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#12972386)\n +- InMemoryTableScan [brand_context_id#12972378, supplier_id#12972379, canonical_id#12972386, is_primary#12972387, entity_name#12972380, city#12972381, state#12972382, country#12972383, threshold#12972388, create_date#12972389], [isnotnull(canonical_id#12972386)]\n +- InMemoryRelation [brand_context_id#12972378, supplier_id#12972379, entity_name#12972380, city#12972381, state#12972382, country#12972383, supplier_type#12972384, declaring_supplier_id#12972385, canonical_id#12972386, is_primary#12972387, threshold#12972388, create_date#12972389], 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 ... [129740] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster322795 {
label="InMemoryTableScan";
129741 [labelType="html" label="MapPartitionsRDD [129741]<br>count at <unknown>:0"];
129742 [labelType="html" label="MapPartitionsRDD [129742]<br>count at <unknown>:0"];
129743 [labelType="html" label="MapPartitionsRDD [129743]<br>count at <unknown>:0"];
}
subgraph cluster322791 {
label="WholeStageCodegen (1)";
129744 [labelType="html" label="MapPartitionsRDD [129744]<br>count at <unknown>:0"];
}
subgraph cluster322790 {
label="Exchange";
129745 [labelType="html" label="MapPartitionsRDD [129745]<br>count at <unknown>:0"];
}
}
129711->129712;
129712->129713;
129713->129714;
129714->129735;
129735->129736;
129736->129737;
129737->129738;
129738->129739;
129739->129740;
129740->129741;
129741->129742;
129742->129743;
129743->129744;
129744->129745;
}
129714
129740