digraph G {
subgraph clusterstage_27645 {
label="Stage 27645";
120939 [labelType="html" label="JDBCRDD [120939]<br>cache at <unknown>:0"];
subgraph cluster302481 {
label="WholeStageCodegen (1)";
120940 [labelType="html" label="MapPartitionsRDD [120940]<br>count at <unknown>:0"];
}
subgraph cluster302483 {
label="mapPartitionsInternal";
120941 [labelType="html" label="MapPartitionsRDD [120941]<br>count at <unknown>:0"];
}
subgraph cluster302484 {
label="mapPartitionsInternal";
120942 [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#12293816,supplier_id#12293817,entity_name#12293818,city#12293819,state#12293820,country#12293821,supplier_type#12293822,declaring_supplier_id#12293823,canonical_id#12293824,is_primary#12293825,threshold#12293826,create_date#12293827] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [120942] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster302516 {
label="InMemoryTableScan";
120951 [labelType="html" label="MapPartitionsRDD [120951]<br>count at <unknown>:0"];
120952 [labelType="html" label="MapPartitionsRDD [120952]<br>count at <unknown>:0"];
120953 [labelType="html" label="MapPartitionsRDD [120953]<br>count at <unknown>:0"];
}
subgraph cluster302511 {
label="WholeStageCodegen (1)";
120954 [labelType="html" label="MapPartitionsRDD [120954]<br>count at <unknown>:0"];
}
subgraph cluster302517 {
label="mapPartitionsInternal";
120955 [labelType="html" label="MapPartitionsRDD [120955]<br>count at <unknown>:0"];
}
subgraph cluster302518 {
label="mapPartitionsInternal";
120956 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#12293816, supplier_id#12293817, entity_name#12293818, city#12293819, state#12293820, country#12293821, supplier_type#12293822, declaring_supplier_id#12293823, threshold#12293826, create_date#12293827]\n +- Filter isnull(canonical_id#12293824)\n +- InMemoryTableScan [brand_context_id#12293816, canonical_id#12293824, city#12293819, country#12293821, create_date#12293827, declaring_supplier_id#12293823, entity_name#12293818, state#12293820, supplier_id#12293817, supplier_type#12293822, threshold#12293826], [isnull(canonical_id#12293824)]\n +- InMemoryRelation [brand_context_id#12293816, supplier_id#12293817, entity_name#12293818, city#12293819, state#12293820, country#12293821, supplier_type#12293822, declaring_supplier_id#12293823, canonical_id#12293824, is_primary#12293825, threshold#12293826, create_date#12293827], StorageLevel(disk, memory, deserialized, 1 replicas)\n +- *(1) Scan JDBCRelation((\n SEL... [120956] [Cached]<br>count at <unknown>:0"];
}
}
120939->120940;
120940->120941;
120941->120942;
120942->120951;
120951->120952;
120952->120953;
120953->120954;
120954->120955;
120955->120956;
}
120942
120956