digraph G {
subgraph clusterstage_26815 {
label="Stage 26815";
118068 [labelType="html" label="JDBCRDD [118068]<br>cache at <unknown>:0"];
subgraph cluster295909 {
label="WholeStageCodegen (1)";
118069 [labelType="html" label="MapPartitionsRDD [118069]<br>count at <unknown>:0"];
}
subgraph cluster295911 {
label="mapPartitionsInternal";
118070 [labelType="html" label="MapPartitionsRDD [118070]<br>count at <unknown>:0"];
}
subgraph cluster295912 {
label="mapPartitionsInternal";
118071 [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#12042094,supplier_id#12042095,entity_name#12042096,city#12042097,state#12042098,country#12042099,supplier_type#12042100,declaring_supplier_id#12042101,canonical_id#12042102,is_primary#12042103,threshold#12042104,create_date#12042105] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [118071] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster295944 {
label="InMemoryTableScan";
118080 [labelType="html" label="MapPartitionsRDD [118080]<br>count at <unknown>:0"];
118081 [labelType="html" label="MapPartitionsRDD [118081]<br>count at <unknown>:0"];
118082 [labelType="html" label="MapPartitionsRDD [118082]<br>count at <unknown>:0"];
}
subgraph cluster295939 {
label="WholeStageCodegen (1)";
118083 [labelType="html" label="MapPartitionsRDD [118083]<br>count at <unknown>:0"];
}
subgraph cluster295945 {
label="mapPartitionsInternal";
118084 [labelType="html" label="MapPartitionsRDD [118084]<br>count at <unknown>:0"];
}
subgraph cluster295946 {
label="mapPartitionsInternal";
118085 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#12042094, supplier_id#12042095, entity_name#12042096, city#12042097, state#12042098, country#12042099, supplier_type#12042100, declaring_supplier_id#12042101, threshold#12042104, create_date#12042105]\n +- Filter isnull(canonical_id#12042102)\n +- InMemoryTableScan [brand_context_id#12042094, canonical_id#12042102, city#12042097, country#12042099, create_date#12042105, declaring_supplier_id#12042101, entity_name#12042096, state#12042098, supplier_id#12042095, supplier_type#12042100, threshold#12042104], [isnull(canonical_id#12042102)]\n +- InMemoryRelation [brand_context_id#12042094, supplier_id#12042095, entity_name#12042096, city#12042097, state#12042098, country#12042099, supplier_type#12042100, declaring_supplier_id#12042101, canonical_id#12042102, is_primary#12042103, threshold#12042104, create_date#12042105], StorageLevel(disk, memory, deserialized, 1 replicas)\n +- *(1) Scan JDBCRelation((\n SEL... [118085] [Cached]<br>count at <unknown>:0"];
}
}
118068->118069;
118069->118070;
118070->118071;
118071->118080;
118080->118081;
118081->118082;
118082->118083;
118083->118084;
118084->118085;
}
118071
118085