digraph G {
subgraph clusterstage_26819 {
label="Stage 26819";
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 cluster295969 {
label="InMemoryTableScan";
118092 [labelType="html" label="MapPartitionsRDD [118092]<br>count at <unknown>:0"];
118093 [labelType="html" label="MapPartitionsRDD [118093]<br>count at <unknown>:0"];
118094 [labelType="html" label="MapPartitionsRDD [118094]<br>count at <unknown>:0"];
}
subgraph cluster295965 {
label="WholeStageCodegen (1)";
118095 [labelType="html" label="MapPartitionsRDD [118095]<br>count at <unknown>:0"];
}
subgraph cluster295970 {
label="mapPartitionsInternal";
118096 [labelType="html" label="MapPartitionsRDD [118096]<br>count at <unknown>:0"];
}
subgraph cluster295971 {
label="mapPartitionsInternal";
118097 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#12042102)\n +- InMemoryTableScan [brand_context_id#12042094, supplier_id#12042095, canonical_id#12042102, is_primary#12042103, entity_name#12042096, city#12042097, state#12042098, country#12042099, threshold#12042104, create_date#12042105], [isnotnull(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 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 ... [118097] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster295977 {
label="InMemoryTableScan";
118098 [labelType="html" label="MapPartitionsRDD [118098]<br>count at <unknown>:0"];
118099 [labelType="html" label="MapPartitionsRDD [118099]<br>count at <unknown>:0"];
118100 [labelType="html" label="MapPartitionsRDD [118100]<br>count at <unknown>:0"];
}
subgraph cluster295973 {
label="WholeStageCodegen (1)";
118101 [labelType="html" label="MapPartitionsRDD [118101]<br>count at <unknown>:0"];
}
subgraph cluster295972 {
label="Exchange";
118102 [labelType="html" label="MapPartitionsRDD [118102]<br>count at <unknown>:0"];
}
}
118068->118069;
118069->118070;
118070->118071;
118071->118092;
118092->118093;
118093->118094;
118094->118095;
118095->118096;
118096->118097;
118097->118098;
118098->118099;
118099->118100;
118100->118101;
118101->118102;
}
118071
118097