digraph G {
subgraph clusterstage_44265 {
label="Stage 44265";
191965 [labelType="html" label="JDBCRDD [191965]<br>cache at <unknown>:0"];
subgraph cluster452685 {
label="WholeStageCodegen (1)";
191966 [labelType="html" label="MapPartitionsRDD [191966]<br>count at <unknown>:0"];
}
subgraph cluster452687 {
label="mapPartitionsInternal";
191967 [labelType="html" label="MapPartitionsRDD [191967]<br>count at <unknown>:0"];
}
subgraph cluster452688 {
label="mapPartitionsInternal";
191968 [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#17324074,supplier_id#17324075,entity_name#17324076,city#17324077,state#17324078,country#17324079,supplier_type#17324080,declaring_supplier_id#17324081,canonical_id#17324082,is_primary#17324083,threshold#17324084,create_date#17324085] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [191968] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster452745 {
label="InMemoryTableScan";
191989 [labelType="html" label="MapPartitionsRDD [191989]<br>count at <unknown>:0"];
191990 [labelType="html" label="MapPartitionsRDD [191990]<br>count at <unknown>:0"];
191991 [labelType="html" label="MapPartitionsRDD [191991]<br>count at <unknown>:0"];
}
subgraph cluster452741 {
label="WholeStageCodegen (1)";
191992 [labelType="html" label="MapPartitionsRDD [191992]<br>count at <unknown>:0"];
}
subgraph cluster452746 {
label="mapPartitionsInternal";
191993 [labelType="html" label="MapPartitionsRDD [191993]<br>count at <unknown>:0"];
}
subgraph cluster452747 {
label="mapPartitionsInternal";
191994 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#17324082)\n +- InMemoryTableScan [brand_context_id#17324074, supplier_id#17324075, canonical_id#17324082, is_primary#17324083, entity_name#17324076, city#17324077, state#17324078, country#17324079, threshold#17324084, create_date#17324085], [isnotnull(canonical_id#17324082)]\n +- InMemoryRelation [brand_context_id#17324074, supplier_id#17324075, entity_name#17324076, city#17324077, state#17324078, country#17324079, supplier_type#17324080, declaring_supplier_id#17324081, canonical_id#17324082, is_primary#17324083, threshold#17324084, create_date#17324085], 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 ... [191994] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster452753 {
label="InMemoryTableScan";
191995 [labelType="html" label="MapPartitionsRDD [191995]<br>count at <unknown>:0"];
191996 [labelType="html" label="MapPartitionsRDD [191996]<br>count at <unknown>:0"];
191997 [labelType="html" label="MapPartitionsRDD [191997]<br>count at <unknown>:0"];
}
subgraph cluster452749 {
label="WholeStageCodegen (1)";
191998 [labelType="html" label="MapPartitionsRDD [191998]<br>count at <unknown>:0"];
}
subgraph cluster452748 {
label="Exchange";
191999 [labelType="html" label="MapPartitionsRDD [191999]<br>count at <unknown>:0"];
}
}
191965->191966;
191966->191967;
191967->191968;
191968->191989;
191989->191990;
191990->191991;
191991->191992;
191992->191993;
191993->191994;
191994->191995;
191995->191996;
191996->191997;
191997->191998;
191998->191999;
}
191968
191994