digraph G {
subgraph clusterstage_36269 {
label="Stage 36269";
157488 [labelType="html" label="JDBCRDD [157488]<br>cache at <unknown>:0"];
subgraph cluster379772 {
label="WholeStageCodegen (1)";
157489 [labelType="html" label="MapPartitionsRDD [157489]<br>count at <unknown>:0"];
}
subgraph cluster379774 {
label="mapPartitionsInternal";
157490 [labelType="html" label="MapPartitionsRDD [157490]<br>count at <unknown>:0"];
}
subgraph cluster379775 {
label="mapPartitionsInternal";
157491 [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#14899903,supplier_id#14899904,entity_name#14899905,city#14899906,state#14899907,country#14899908,supplier_type#14899909,declaring_supplier_id#14899910,canonical_id#14899911,is_primary#14899912,threshold#14899913,create_date#14899914] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [157491] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster379832 {
label="InMemoryTableScan";
157512 [labelType="html" label="MapPartitionsRDD [157512]<br>count at <unknown>:0"];
157513 [labelType="html" label="MapPartitionsRDD [157513]<br>count at <unknown>:0"];
157514 [labelType="html" label="MapPartitionsRDD [157514]<br>count at <unknown>:0"];
}
subgraph cluster379828 {
label="WholeStageCodegen (1)";
157515 [labelType="html" label="MapPartitionsRDD [157515]<br>count at <unknown>:0"];
}
subgraph cluster379833 {
label="mapPartitionsInternal";
157516 [labelType="html" label="MapPartitionsRDD [157516]<br>count at <unknown>:0"];
}
subgraph cluster379834 {
label="mapPartitionsInternal";
157517 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#14899911)\n +- InMemoryTableScan [brand_context_id#14899903, supplier_id#14899904, canonical_id#14899911, is_primary#14899912, entity_name#14899905, city#14899906, state#14899907, country#14899908, threshold#14899913, create_date#14899914], [isnotnull(canonical_id#14899911)]\n +- InMemoryRelation [brand_context_id#14899903, supplier_id#14899904, entity_name#14899905, city#14899906, state#14899907, country#14899908, supplier_type#14899909, declaring_supplier_id#14899910, canonical_id#14899911, is_primary#14899912, threshold#14899913, create_date#14899914], 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 ... [157517] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster379840 {
label="InMemoryTableScan";
157518 [labelType="html" label="MapPartitionsRDD [157518]<br>count at <unknown>:0"];
157519 [labelType="html" label="MapPartitionsRDD [157519]<br>count at <unknown>:0"];
157520 [labelType="html" label="MapPartitionsRDD [157520]<br>count at <unknown>:0"];
}
subgraph cluster379836 {
label="WholeStageCodegen (1)";
157521 [labelType="html" label="MapPartitionsRDD [157521]<br>count at <unknown>:0"];
}
subgraph cluster379835 {
label="Exchange";
157522 [labelType="html" label="MapPartitionsRDD [157522]<br>count at <unknown>:0"];
}
}
157488->157489;
157489->157490;
157490->157491;
157491->157512;
157512->157513;
157513->157514;
157514->157515;
157515->157516;
157516->157517;
157517->157518;
157518->157519;
157519->157520;
157520->157521;
157521->157522;
}
157491
157517