digraph G {
subgraph clusterstage_2610 {
label="Stage 2610";
9335 [labelType="html" label="JDBCRDD [9335]<br>cache at <unknown>:0"];
subgraph cluster21297 {
label="WholeStageCodegen (1)";
9336 [labelType="html" label="MapPartitionsRDD [9336]<br>count at <unknown>:0"];
}
subgraph cluster21299 {
label="mapPartitionsInternal";
9337 [labelType="html" label="MapPartitionsRDD [9337]<br>count at <unknown>:0"];
}
subgraph cluster21300 {
label="mapPartitionsInternal";
9338 [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#826215,supplier_id#826216,entity_name#826217,city#826218,state#826219,country#826220,supplier_type#826221,declaring_supplier_id#826222,canonical_id#826223,is_primary#826224,threshold#826225,create_date#826226] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [9338] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster21357 {
label="InMemoryTableScan";
9359 [labelType="html" label="MapPartitionsRDD [9359]<br>count at <unknown>:0"];
9360 [labelType="html" label="MapPartitionsRDD [9360]<br>count at <unknown>:0"];
9361 [labelType="html" label="MapPartitionsRDD [9361]<br>count at <unknown>:0"];
}
subgraph cluster21353 {
label="WholeStageCodegen (1)";
9362 [labelType="html" label="MapPartitionsRDD [9362]<br>count at <unknown>:0"];
}
subgraph cluster21358 {
label="mapPartitionsInternal";
9363 [labelType="html" label="MapPartitionsRDD [9363]<br>count at <unknown>:0"];
}
subgraph cluster21359 {
label="mapPartitionsInternal";
9364 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#826223)\n +- InMemoryTableScan [brand_context_id#826215, supplier_id#826216, canonical_id#826223, is_primary#826224, entity_name#826217, city#826218, state#826219, country#826220, threshold#826225, create_date#826226], [isnotnull(canonical_id#826223)]\n +- InMemoryRelation [brand_context_id#826215, supplier_id#826216, entity_name#826217, city#826218, state#826219, country#826220, supplier_type#826221, declaring_supplier_id#826222, canonical_id#826223, is_primary#826224, threshold#826225, create_date#826226], 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 v.canonical_id,\n v.is_prima... [9364] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster21365 {
label="InMemoryTableScan";
9365 [labelType="html" label="MapPartitionsRDD [9365]<br>count at <unknown>:0"];
9366 [labelType="html" label="MapPartitionsRDD [9366]<br>count at <unknown>:0"];
9367 [labelType="html" label="MapPartitionsRDD [9367]<br>count at <unknown>:0"];
}
subgraph cluster21361 {
label="WholeStageCodegen (1)";
9368 [labelType="html" label="MapPartitionsRDD [9368]<br>count at <unknown>:0"];
}
subgraph cluster21360 {
label="Exchange";
9369 [labelType="html" label="MapPartitionsRDD [9369]<br>count at <unknown>:0"];
}
}
9335->9336;
9336->9337;
9337->9338;
9338->9359;
9359->9360;
9360->9361;
9361->9362;
9362->9363;
9363->9364;
9364->9365;
9365->9366;
9366->9367;
9367->9368;
9368->9369;
}
9338
9364