digraph G {
subgraph clusterstage_43694 {
label="Stage 43694";
189999 [labelType="html" label="JDBCRDD [189999]<br>cache at <unknown>:0"];
subgraph cluster447968 {
label="WholeStageCodegen (1)";
190000 [labelType="html" label="MapPartitionsRDD [190000]<br>count at <unknown>:0"];
}
subgraph cluster447970 {
label="mapPartitionsInternal";
190001 [labelType="html" label="MapPartitionsRDD [190001]<br>count at <unknown>:0"];
}
subgraph cluster447971 {
label="mapPartitionsInternal";
190002 [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#17247862,supplier_id#17247863,entity_name#17247864,city#17247865,state#17247866,country#17247867,supplier_type#17247868,declaring_supplier_id#17247869,canonical_id#17247870,is_primary#17247871,threshold#17247872,create_date#17247873] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [190002] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster448028 {
label="InMemoryTableScan";
190023 [labelType="html" label="MapPartitionsRDD [190023]<br>count at <unknown>:0"];
190024 [labelType="html" label="MapPartitionsRDD [190024]<br>count at <unknown>:0"];
190025 [labelType="html" label="MapPartitionsRDD [190025]<br>count at <unknown>:0"];
}
subgraph cluster448024 {
label="WholeStageCodegen (1)";
190026 [labelType="html" label="MapPartitionsRDD [190026]<br>count at <unknown>:0"];
}
subgraph cluster448029 {
label="mapPartitionsInternal";
190027 [labelType="html" label="MapPartitionsRDD [190027]<br>count at <unknown>:0"];
}
subgraph cluster448030 {
label="mapPartitionsInternal";
190028 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#17247870)\n +- InMemoryTableScan [brand_context_id#17247862, supplier_id#17247863, canonical_id#17247870, is_primary#17247871, entity_name#17247864, city#17247865, state#17247866, country#17247867, threshold#17247872, create_date#17247873], [isnotnull(canonical_id#17247870)]\n +- InMemoryRelation [brand_context_id#17247862, supplier_id#17247863, entity_name#17247864, city#17247865, state#17247866, country#17247867, supplier_type#17247868, declaring_supplier_id#17247869, canonical_id#17247870, is_primary#17247871, threshold#17247872, create_date#17247873], 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 ... [190028] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster448036 {
label="InMemoryTableScan";
190029 [labelType="html" label="MapPartitionsRDD [190029]<br>count at <unknown>:0"];
190030 [labelType="html" label="MapPartitionsRDD [190030]<br>count at <unknown>:0"];
190031 [labelType="html" label="MapPartitionsRDD [190031]<br>count at <unknown>:0"];
}
subgraph cluster448032 {
label="WholeStageCodegen (1)";
190032 [labelType="html" label="MapPartitionsRDD [190032]<br>count at <unknown>:0"];
}
subgraph cluster448031 {
label="Exchange";
190033 [labelType="html" label="MapPartitionsRDD [190033]<br>count at <unknown>:0"];
}
}
189999->190000;
190000->190001;
190001->190002;
190002->190023;
190023->190024;
190024->190025;
190025->190026;
190026->190027;
190027->190028;
190028->190029;
190029->190030;
190030->190031;
190031->190032;
190032->190033;
}
190002
190028