digraph G {
subgraph clusterstage_42974 {
label="Stage 42974";
187508 [labelType="html" label="JDBCRDD [187508]<br>cache at <unknown>:0"];
subgraph cluster442306 {
label="WholeStageCodegen (1)";
187509 [labelType="html" label="MapPartitionsRDD [187509]<br>count at <unknown>:0"];
}
subgraph cluster442308 {
label="mapPartitionsInternal";
187510 [labelType="html" label="MapPartitionsRDD [187510]<br>count at <unknown>:0"];
}
subgraph cluster442309 {
label="mapPartitionsInternal";
187511 [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#17010950,supplier_id#17010951,entity_name#17010952,city#17010953,state#17010954,country#17010955,supplier_type#17010956,declaring_supplier_id#17010957,canonical_id#17010958,is_primary#17010959,threshold#17010960,create_date#17010961] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [187511] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster442366 {
label="InMemoryTableScan";
187532 [labelType="html" label="MapPartitionsRDD [187532]<br>count at <unknown>:0"];
187533 [labelType="html" label="MapPartitionsRDD [187533]<br>count at <unknown>:0"];
187534 [labelType="html" label="MapPartitionsRDD [187534]<br>count at <unknown>:0"];
}
subgraph cluster442362 {
label="WholeStageCodegen (1)";
187535 [labelType="html" label="MapPartitionsRDD [187535]<br>count at <unknown>:0"];
}
subgraph cluster442367 {
label="mapPartitionsInternal";
187536 [labelType="html" label="MapPartitionsRDD [187536]<br>count at <unknown>:0"];
}
subgraph cluster442368 {
label="mapPartitionsInternal";
187537 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#17010958)\n +- InMemoryTableScan [brand_context_id#17010950, supplier_id#17010951, canonical_id#17010958, is_primary#17010959, entity_name#17010952, city#17010953, state#17010954, country#17010955, threshold#17010960, create_date#17010961], [isnotnull(canonical_id#17010958)]\n +- InMemoryRelation [brand_context_id#17010950, supplier_id#17010951, entity_name#17010952, city#17010953, state#17010954, country#17010955, supplier_type#17010956, declaring_supplier_id#17010957, canonical_id#17010958, is_primary#17010959, threshold#17010960, create_date#17010961], 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 ... [187537] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster442374 {
label="InMemoryTableScan";
187538 [labelType="html" label="MapPartitionsRDD [187538]<br>count at <unknown>:0"];
187539 [labelType="html" label="MapPartitionsRDD [187539]<br>count at <unknown>:0"];
187540 [labelType="html" label="MapPartitionsRDD [187540]<br>count at <unknown>:0"];
}
subgraph cluster442370 {
label="WholeStageCodegen (1)";
187541 [labelType="html" label="MapPartitionsRDD [187541]<br>count at <unknown>:0"];
}
subgraph cluster442369 {
label="Exchange";
187542 [labelType="html" label="MapPartitionsRDD [187542]<br>count at <unknown>:0"];
}
}
187508->187509;
187509->187510;
187510->187511;
187511->187532;
187532->187533;
187533->187534;
187534->187535;
187535->187536;
187536->187537;
187537->187538;
187538->187539;
187539->187540;
187540->187541;
187541->187542;
}
187511
187537