digraph G {
subgraph clusterstage_27649 {
label="Stage 27649";
120939 [labelType="html" label="JDBCRDD [120939]<br>cache at <unknown>:0"];
subgraph cluster302481 {
label="WholeStageCodegen (1)";
120940 [labelType="html" label="MapPartitionsRDD [120940]<br>count at <unknown>:0"];
}
subgraph cluster302483 {
label="mapPartitionsInternal";
120941 [labelType="html" label="MapPartitionsRDD [120941]<br>count at <unknown>:0"];
}
subgraph cluster302484 {
label="mapPartitionsInternal";
120942 [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#12293816,supplier_id#12293817,entity_name#12293818,city#12293819,state#12293820,country#12293821,supplier_type#12293822,declaring_supplier_id#12293823,canonical_id#12293824,is_primary#12293825,threshold#12293826,create_date#12293827] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [120942] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster302541 {
label="InMemoryTableScan";
120963 [labelType="html" label="MapPartitionsRDD [120963]<br>count at <unknown>:0"];
120964 [labelType="html" label="MapPartitionsRDD [120964]<br>count at <unknown>:0"];
120965 [labelType="html" label="MapPartitionsRDD [120965]<br>count at <unknown>:0"];
}
subgraph cluster302537 {
label="WholeStageCodegen (1)";
120966 [labelType="html" label="MapPartitionsRDD [120966]<br>count at <unknown>:0"];
}
subgraph cluster302542 {
label="mapPartitionsInternal";
120967 [labelType="html" label="MapPartitionsRDD [120967]<br>count at <unknown>:0"];
}
subgraph cluster302543 {
label="mapPartitionsInternal";
120968 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#12293824)\n +- InMemoryTableScan [brand_context_id#12293816, supplier_id#12293817, canonical_id#12293824, is_primary#12293825, entity_name#12293818, city#12293819, state#12293820, country#12293821, threshold#12293826, create_date#12293827], [isnotnull(canonical_id#12293824)]\n +- InMemoryRelation [brand_context_id#12293816, supplier_id#12293817, entity_name#12293818, city#12293819, state#12293820, country#12293821, supplier_type#12293822, declaring_supplier_id#12293823, canonical_id#12293824, is_primary#12293825, threshold#12293826, create_date#12293827], 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 ... [120968] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster302549 {
label="InMemoryTableScan";
120969 [labelType="html" label="MapPartitionsRDD [120969]<br>count at <unknown>:0"];
120970 [labelType="html" label="MapPartitionsRDD [120970]<br>count at <unknown>:0"];
120971 [labelType="html" label="MapPartitionsRDD [120971]<br>count at <unknown>:0"];
}
subgraph cluster302545 {
label="WholeStageCodegen (1)";
120972 [labelType="html" label="MapPartitionsRDD [120972]<br>count at <unknown>:0"];
}
subgraph cluster302544 {
label="Exchange";
120973 [labelType="html" label="MapPartitionsRDD [120973]<br>count at <unknown>:0"];
}
}
120939->120940;
120940->120941;
120941->120942;
120942->120963;
120963->120964;
120964->120965;
120965->120966;
120966->120967;
120967->120968;
120968->120969;
120969->120970;
120970->120971;
120971->120972;
120972->120973;
}
120942
120968