digraph G {
subgraph clusterstage_43858 {
label="Stage 43858";
190569 [labelType="html" label="JDBCRDD [190569]<br>cache at <unknown>:0"];
subgraph cluster449333 {
label="WholeStageCodegen (1)";
190570 [labelType="html" label="MapPartitionsRDD [190570]<br>count at <unknown>:0"];
}
subgraph cluster449335 {
label="mapPartitionsInternal";
190571 [labelType="html" label="MapPartitionsRDD [190571]<br>count at <unknown>:0"];
}
subgraph cluster449336 {
label="mapPartitionsInternal";
190572 [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#17270077,supplier_id#17270078,entity_name#17270079,city#17270080,state#17270081,country#17270082,supplier_type#17270083,declaring_supplier_id#17270084,canonical_id#17270085,is_primary#17270086,threshold#17270087,create_date#17270088] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [190572] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster449393 {
label="InMemoryTableScan";
190593 [labelType="html" label="MapPartitionsRDD [190593]<br>count at <unknown>:0"];
190594 [labelType="html" label="MapPartitionsRDD [190594]<br>count at <unknown>:0"];
190595 [labelType="html" label="MapPartitionsRDD [190595]<br>count at <unknown>:0"];
}
subgraph cluster449389 {
label="WholeStageCodegen (1)";
190596 [labelType="html" label="MapPartitionsRDD [190596]<br>count at <unknown>:0"];
}
subgraph cluster449394 {
label="mapPartitionsInternal";
190597 [labelType="html" label="MapPartitionsRDD [190597]<br>count at <unknown>:0"];
}
subgraph cluster449395 {
label="mapPartitionsInternal";
190598 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#17270085)\n +- InMemoryTableScan [brand_context_id#17270077, supplier_id#17270078, canonical_id#17270085, is_primary#17270086, entity_name#17270079, city#17270080, state#17270081, country#17270082, threshold#17270087, create_date#17270088], [isnotnull(canonical_id#17270085)]\n +- InMemoryRelation [brand_context_id#17270077, supplier_id#17270078, entity_name#17270079, city#17270080, state#17270081, country#17270082, supplier_type#17270083, declaring_supplier_id#17270084, canonical_id#17270085, is_primary#17270086, threshold#17270087, create_date#17270088], 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 ... [190598] [Cached]<br>count at <unknown>:0"];
}
}
190569->190570;
190570->190571;
190571->190572;
190572->190593;
190593->190594;
190594->190595;
190595->190596;
190596->190597;
190597->190598;
}
190572
190598