digraph G {
subgraph clusterstage_27726 {
label="Stage 27726";
121205 [labelType="html" label="JDBCRDD [121205]<br>cache at <unknown>:0"];
subgraph cluster303118 {
label="WholeStageCodegen (1)";
121206 [labelType="html" label="MapPartitionsRDD [121206]<br>count at <unknown>:0"];
}
subgraph cluster303120 {
label="mapPartitionsInternal";
121207 [labelType="html" label="MapPartitionsRDD [121207]<br>count at <unknown>:0"];
}
subgraph cluster303121 {
label="mapPartitionsInternal";
121208 [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#12304183,supplier_id#12304184,entity_name#12304185,city#12304186,state#12304187,country#12304188,supplier_type#12304189,declaring_supplier_id#12304190,canonical_id#12304191,is_primary#12304192,threshold#12304193,create_date#12304194] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [121208] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster303178 {
label="InMemoryTableScan";
121229 [labelType="html" label="MapPartitionsRDD [121229]<br>count at <unknown>:0"];
121230 [labelType="html" label="MapPartitionsRDD [121230]<br>count at <unknown>:0"];
121231 [labelType="html" label="MapPartitionsRDD [121231]<br>count at <unknown>:0"];
}
subgraph cluster303174 {
label="WholeStageCodegen (1)";
121232 [labelType="html" label="MapPartitionsRDD [121232]<br>count at <unknown>:0"];
}
subgraph cluster303179 {
label="mapPartitionsInternal";
121233 [labelType="html" label="MapPartitionsRDD [121233]<br>count at <unknown>:0"];
}
subgraph cluster303180 {
label="mapPartitionsInternal";
121234 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#12304191)\n +- InMemoryTableScan [brand_context_id#12304183, supplier_id#12304184, canonical_id#12304191, is_primary#12304192, entity_name#12304185, city#12304186, state#12304187, country#12304188, threshold#12304193, create_date#12304194], [isnotnull(canonical_id#12304191)]\n +- InMemoryRelation [brand_context_id#12304183, supplier_id#12304184, entity_name#12304185, city#12304186, state#12304187, country#12304188, supplier_type#12304189, declaring_supplier_id#12304190, canonical_id#12304191, is_primary#12304192, threshold#12304193, create_date#12304194], 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 ... [121234] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster303186 {
label="InMemoryTableScan";
121235 [labelType="html" label="MapPartitionsRDD [121235]<br>count at <unknown>:0"];
121236 [labelType="html" label="MapPartitionsRDD [121236]<br>count at <unknown>:0"];
121237 [labelType="html" label="MapPartitionsRDD [121237]<br>count at <unknown>:0"];
}
subgraph cluster303182 {
label="WholeStageCodegen (1)";
121238 [labelType="html" label="MapPartitionsRDD [121238]<br>count at <unknown>:0"];
}
subgraph cluster303181 {
label="Exchange";
121239 [labelType="html" label="MapPartitionsRDD [121239]<br>count at <unknown>:0"];
}
}
121205->121206;
121206->121207;
121207->121208;
121208->121229;
121229->121230;
121230->121231;
121231->121232;
121232->121233;
121233->121234;
121234->121235;
121235->121236;
121236->121237;
121237->121238;
121238->121239;
}
121208
121234