digraph G {
subgraph clusterstage_35229 {
label="Stage 35229";
153895 [labelType="html" label="JDBCRDD [153895]<br>cache at <unknown>:0"];
subgraph cluster371471 {
label="WholeStageCodegen (1)";
153896 [labelType="html" label="MapPartitionsRDD [153896]<br>count at <unknown>:0"];
}
subgraph cluster371473 {
label="mapPartitionsInternal";
153897 [labelType="html" label="MapPartitionsRDD [153897]<br>count at <unknown>:0"];
}
subgraph cluster371474 {
label="mapPartitionsInternal";
153898 [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#14620042,supplier_id#14620043,entity_name#14620044,city#14620045,state#14620046,country#14620047,supplier_type#14620048,declaring_supplier_id#14620049,canonical_id#14620050,is_primary#14620051,threshold#14620052,create_date#14620053] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [153898] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster371531 {
label="InMemoryTableScan";
153919 [labelType="html" label="MapPartitionsRDD [153919]<br>count at <unknown>:0"];
153920 [labelType="html" label="MapPartitionsRDD [153920]<br>count at <unknown>:0"];
153921 [labelType="html" label="MapPartitionsRDD [153921]<br>count at <unknown>:0"];
}
subgraph cluster371527 {
label="WholeStageCodegen (1)";
153922 [labelType="html" label="MapPartitionsRDD [153922]<br>count at <unknown>:0"];
}
subgraph cluster371532 {
label="mapPartitionsInternal";
153923 [labelType="html" label="MapPartitionsRDD [153923]<br>count at <unknown>:0"];
}
subgraph cluster371533 {
label="mapPartitionsInternal";
153924 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#14620050)\n +- InMemoryTableScan [brand_context_id#14620042, supplier_id#14620043, canonical_id#14620050, is_primary#14620051, entity_name#14620044, city#14620045, state#14620046, country#14620047, threshold#14620052, create_date#14620053], [isnotnull(canonical_id#14620050)]\n +- InMemoryRelation [brand_context_id#14620042, supplier_id#14620043, entity_name#14620044, city#14620045, state#14620046, country#14620047, supplier_type#14620048, declaring_supplier_id#14620049, canonical_id#14620050, is_primary#14620051, threshold#14620052, create_date#14620053], 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 ... [153924] [Cached]<br>count at <unknown>:0"];
}
}
153895->153896;
153896->153897;
153897->153898;
153898->153919;
153919->153920;
153920->153921;
153921->153922;
153922->153923;
153923->153924;
}
153898
153924