digraph G {
subgraph clusterstage_1343 {
label="Stage 1343";
4619 [labelType="html" label="JDBCRDD [4619]<br>cache at <unknown>:0"];
subgraph cluster10758 {
label="WholeStageCodegen (1)";
4620 [labelType="html" label="MapPartitionsRDD [4620]<br>count at <unknown>:0"];
}
subgraph cluster10760 {
label="mapPartitionsInternal";
4621 [labelType="html" label="MapPartitionsRDD [4621]<br>count at <unknown>:0"];
}
subgraph cluster10761 {
label="mapPartitionsInternal";
4622 [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#319848,supplier_id#319849,entity_name#319850,city#319851,state#319852,country#319853,supplier_type#319854,declaring_supplier_id#319855,canonical_id#319856,is_primary#319857,threshold#319858,create_date#319859] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [4622] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster10818 {
label="InMemoryTableScan";
4643 [labelType="html" label="MapPartitionsRDD [4643]<br>count at <unknown>:0"];
4644 [labelType="html" label="MapPartitionsRDD [4644]<br>count at <unknown>:0"];
4645 [labelType="html" label="MapPartitionsRDD [4645]<br>count at <unknown>:0"];
}
subgraph cluster10814 {
label="WholeStageCodegen (1)";
4646 [labelType="html" label="MapPartitionsRDD [4646]<br>count at <unknown>:0"];
}
subgraph cluster10819 {
label="mapPartitionsInternal";
4647 [labelType="html" label="MapPartitionsRDD [4647]<br>count at <unknown>:0"];
}
subgraph cluster10820 {
label="mapPartitionsInternal";
4648 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#319856)\n +- InMemoryTableScan [brand_context_id#319848, supplier_id#319849, canonical_id#319856, is_primary#319857, entity_name#319850, city#319851, state#319852, country#319853, threshold#319858, create_date#319859], [isnotnull(canonical_id#319856)]\n +- InMemoryRelation [brand_context_id#319848, supplier_id#319849, entity_name#319850, city#319851, state#319852, country#319853, supplier_type#319854, declaring_supplier_id#319855, canonical_id#319856, is_primary#319857, threshold#319858, create_date#319859], 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... [4648] [Cached]<br>count at <unknown>:0"];
}
}
4619->4620;
4620->4621;
4621->4622;
4622->4643;
4643->4644;
4644->4645;
4645->4646;
4646->4647;
4647->4648;
}
4622
4648