digraph G {
subgraph clusterstage_42970 {
label="Stage 42970";
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 cluster442341 {
label="InMemoryTableScan";
187520 [labelType="html" label="MapPartitionsRDD [187520]<br>count at <unknown>:0"];
187521 [labelType="html" label="MapPartitionsRDD [187521]<br>count at <unknown>:0"];
187522 [labelType="html" label="MapPartitionsRDD [187522]<br>count at <unknown>:0"];
}
subgraph cluster442336 {
label="WholeStageCodegen (1)";
187523 [labelType="html" label="MapPartitionsRDD [187523]<br>count at <unknown>:0"];
}
subgraph cluster442342 {
label="mapPartitionsInternal";
187524 [labelType="html" label="MapPartitionsRDD [187524]<br>count at <unknown>:0"];
}
subgraph cluster442343 {
label="mapPartitionsInternal";
187525 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#17010950, supplier_id#17010951, entity_name#17010952, city#17010953, state#17010954, country#17010955, supplier_type#17010956, declaring_supplier_id#17010957, threshold#17010960, create_date#17010961]\n +- Filter isnull(canonical_id#17010958)\n +- InMemoryTableScan [brand_context_id#17010950, canonical_id#17010958, city#17010953, country#17010955, create_date#17010961, declaring_supplier_id#17010957, entity_name#17010952, state#17010954, supplier_id#17010951, supplier_type#17010956, threshold#17010960], [isnull(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 SEL... [187525] [Cached]<br>count at <unknown>:0"];
}
}
187508->187509;
187509->187510;
187510->187511;
187511->187520;
187520->187521;
187521->187522;
187522->187523;
187523->187524;
187524->187525;
}
187511
187525