digraph G {
subgraph clusterstage_43848 {
label="Stage 43848";
190531 [labelType="html" label="JDBCRDD [190531]<br>cache at <unknown>:0"];
subgraph cluster449242 {
label="WholeStageCodegen (1)";
190532 [labelType="html" label="MapPartitionsRDD [190532]<br>count at <unknown>:0"];
}
subgraph cluster449244 {
label="mapPartitionsInternal";
190533 [labelType="html" label="MapPartitionsRDD [190533]<br>count at <unknown>:0"];
}
subgraph cluster449245 {
label="mapPartitionsInternal";
190534 [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#17268596,supplier_id#17268597,entity_name#17268598,city#17268599,state#17268600,country#17268601,supplier_type#17268602,declaring_supplier_id#17268603,canonical_id#17268604,is_primary#17268605,threshold#17268606,create_date#17268607] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [190534] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster449302 {
label="InMemoryTableScan";
190555 [labelType="html" label="MapPartitionsRDD [190555]<br>count at <unknown>:0"];
190556 [labelType="html" label="MapPartitionsRDD [190556]<br>count at <unknown>:0"];
190557 [labelType="html" label="MapPartitionsRDD [190557]<br>count at <unknown>:0"];
}
subgraph cluster449298 {
label="WholeStageCodegen (1)";
190558 [labelType="html" label="MapPartitionsRDD [190558]<br>count at <unknown>:0"];
}
subgraph cluster449303 {
label="mapPartitionsInternal";
190559 [labelType="html" label="MapPartitionsRDD [190559]<br>count at <unknown>:0"];
}
subgraph cluster449304 {
label="mapPartitionsInternal";
190560 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#17268604)\n +- InMemoryTableScan [brand_context_id#17268596, supplier_id#17268597, canonical_id#17268604, is_primary#17268605, entity_name#17268598, city#17268599, state#17268600, country#17268601, threshold#17268606, create_date#17268607], [isnotnull(canonical_id#17268604)]\n +- InMemoryRelation [brand_context_id#17268596, supplier_id#17268597, entity_name#17268598, city#17268599, state#17268600, country#17268601, supplier_type#17268602, declaring_supplier_id#17268603, canonical_id#17268604, is_primary#17268605, threshold#17268606, create_date#17268607], 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 ... [190560] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster449310 {
label="InMemoryTableScan";
190561 [labelType="html" label="MapPartitionsRDD [190561]<br>count at <unknown>:0"];
190562 [labelType="html" label="MapPartitionsRDD [190562]<br>count at <unknown>:0"];
190563 [labelType="html" label="MapPartitionsRDD [190563]<br>count at <unknown>:0"];
}
subgraph cluster449306 {
label="WholeStageCodegen (1)";
190564 [labelType="html" label="MapPartitionsRDD [190564]<br>count at <unknown>:0"];
}
subgraph cluster449305 {
label="Exchange";
190565 [labelType="html" label="MapPartitionsRDD [190565]<br>count at <unknown>:0"];
}
}
190531->190532;
190532->190533;
190533->190534;
190534->190555;
190555->190556;
190556->190557;
190557->190558;
190558->190559;
190559->190560;
190560->190561;
190561->190562;
190562->190563;
190563->190564;
190564->190565;
}
190534
190560