digraph G {
subgraph clusterstage_28754 {
label="Stage 28754";
124760 [labelType="html" label="JDBCRDD [124760]<br>cache at <unknown>:0"];
subgraph cluster311328 {
label="WholeStageCodegen (1)";
124761 [labelType="html" label="MapPartitionsRDD [124761]<br>count at <unknown>:0"];
}
subgraph cluster311330 {
label="mapPartitionsInternal";
124762 [labelType="html" label="MapPartitionsRDD [124762]<br>count at <unknown>:0"];
}
subgraph cluster311331 {
label="mapPartitionsInternal";
124763 [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#12582563,supplier_id#12582564,entity_name#12582565,city#12582566,state#12582567,country#12582568,supplier_type#12582569,declaring_supplier_id#12582570,canonical_id#12582571,is_primary#12582572,threshold#12582573,create_date#12582574] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [124763] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster311388 {
label="InMemoryTableScan";
124784 [labelType="html" label="MapPartitionsRDD [124784]<br>count at <unknown>:0"];
124785 [labelType="html" label="MapPartitionsRDD [124785]<br>count at <unknown>:0"];
124786 [labelType="html" label="MapPartitionsRDD [124786]<br>count at <unknown>:0"];
}
subgraph cluster311384 {
label="WholeStageCodegen (1)";
124787 [labelType="html" label="MapPartitionsRDD [124787]<br>count at <unknown>:0"];
}
subgraph cluster311389 {
label="mapPartitionsInternal";
124788 [labelType="html" label="MapPartitionsRDD [124788]<br>count at <unknown>:0"];
}
subgraph cluster311390 {
label="mapPartitionsInternal";
124789 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#12582571)\n +- InMemoryTableScan [brand_context_id#12582563, supplier_id#12582564, canonical_id#12582571, is_primary#12582572, entity_name#12582565, city#12582566, state#12582567, country#12582568, threshold#12582573, create_date#12582574], [isnotnull(canonical_id#12582571)]\n +- InMemoryRelation [brand_context_id#12582563, supplier_id#12582564, entity_name#12582565, city#12582566, state#12582567, country#12582568, supplier_type#12582569, declaring_supplier_id#12582570, canonical_id#12582571, is_primary#12582572, threshold#12582573, create_date#12582574], 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 ... [124789] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster311396 {
label="InMemoryTableScan";
124790 [labelType="html" label="MapPartitionsRDD [124790]<br>count at <unknown>:0"];
124791 [labelType="html" label="MapPartitionsRDD [124791]<br>count at <unknown>:0"];
124792 [labelType="html" label="MapPartitionsRDD [124792]<br>count at <unknown>:0"];
}
subgraph cluster311392 {
label="WholeStageCodegen (1)";
124793 [labelType="html" label="MapPartitionsRDD [124793]<br>count at <unknown>:0"];
}
subgraph cluster311391 {
label="Exchange";
124794 [labelType="html" label="MapPartitionsRDD [124794]<br>count at <unknown>:0"];
}
}
124760->124761;
124761->124762;
124762->124763;
124763->124784;
124784->124785;
124785->124786;
124786->124787;
124787->124788;
124788->124789;
124789->124790;
124790->124791;
124791->124792;
124792->124793;
124793->124794;
}
124763
124789