digraph G {
subgraph clusterstage_30931 {
label="Stage 30931";
132392 [labelType="html" label="JDBCRDD [132392]<br>cache at <unknown>:0"];
subgraph cluster328844 {
label="WholeStageCodegen (1)";
132393 [labelType="html" label="MapPartitionsRDD [132393]<br>count at <unknown>:0"];
}
subgraph cluster328846 {
label="mapPartitionsInternal";
132394 [labelType="html" label="MapPartitionsRDD [132394]<br>count at <unknown>:0"];
}
subgraph cluster328847 {
label="mapPartitionsInternal";
132395 [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#13216695,supplier_id#13216696,entity_name#13216697,city#13216698,state#13216699,country#13216700,supplier_type#13216701,declaring_supplier_id#13216702,canonical_id#13216703,is_primary#13216704,threshold#13216705,create_date#13216706] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [132395] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster328904 {
label="InMemoryTableScan";
132416 [labelType="html" label="MapPartitionsRDD [132416]<br>count at <unknown>:0"];
132417 [labelType="html" label="MapPartitionsRDD [132417]<br>count at <unknown>:0"];
132418 [labelType="html" label="MapPartitionsRDD [132418]<br>count at <unknown>:0"];
}
subgraph cluster328900 {
label="WholeStageCodegen (1)";
132419 [labelType="html" label="MapPartitionsRDD [132419]<br>count at <unknown>:0"];
}
subgraph cluster328905 {
label="mapPartitionsInternal";
132420 [labelType="html" label="MapPartitionsRDD [132420]<br>count at <unknown>:0"];
}
subgraph cluster328906 {
label="mapPartitionsInternal";
132421 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#13216703)\n +- InMemoryTableScan [brand_context_id#13216695, supplier_id#13216696, canonical_id#13216703, is_primary#13216704, entity_name#13216697, city#13216698, state#13216699, country#13216700, threshold#13216705, create_date#13216706], [isnotnull(canonical_id#13216703)]\n +- InMemoryRelation [brand_context_id#13216695, supplier_id#13216696, entity_name#13216697, city#13216698, state#13216699, country#13216700, supplier_type#13216701, declaring_supplier_id#13216702, canonical_id#13216703, is_primary#13216704, threshold#13216705, create_date#13216706], 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 ... [132421] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster328912 {
label="InMemoryTableScan";
132422 [labelType="html" label="MapPartitionsRDD [132422]<br>count at <unknown>:0"];
132423 [labelType="html" label="MapPartitionsRDD [132423]<br>count at <unknown>:0"];
132424 [labelType="html" label="MapPartitionsRDD [132424]<br>count at <unknown>:0"];
}
subgraph cluster328908 {
label="WholeStageCodegen (1)";
132425 [labelType="html" label="MapPartitionsRDD [132425]<br>count at <unknown>:0"];
}
subgraph cluster328907 {
label="Exchange";
132426 [labelType="html" label="MapPartitionsRDD [132426]<br>count at <unknown>:0"];
}
}
132392->132393;
132393->132394;
132394->132395;
132395->132416;
132416->132417;
132417->132418;
132418->132419;
132419->132420;
132420->132421;
132421->132422;
132422->132423;
132423->132424;
132424->132425;
132425->132426;
}
132395
132421