digraph G {
subgraph clusterstage_52 {
label="Stage 52";
152 [labelType="html" label="JDBCRDD [152]<br>cache at <unknown>:0"];
subgraph cluster364 {
label="WholeStageCodegen (1)";
153 [labelType="html" label="MapPartitionsRDD [153]<br>count at <unknown>:0"];
}
subgraph cluster366 {
label="mapPartitionsInternal";
154 [labelType="html" label="MapPartitionsRDD [154]<br>count at <unknown>:0"];
}
subgraph cluster367 {
label="mapPartitionsInternal";
155 [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#5924,supplier_id#5925,entity_name#5926,city#5927,state#5928,country#5929,supplier_type#5930,declaring_supplier_id#5931,canonical_id#5932,is_primary#5933,threshold#5934,create_date#5935] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [155] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster424 {
label="InMemoryTableScan";
176 [labelType="html" label="MapPartitionsRDD [176]<br>count at <unknown>:0"];
177 [labelType="html" label="MapPartitionsRDD [177]<br>count at <unknown>:0"];
178 [labelType="html" label="MapPartitionsRDD [178]<br>count at <unknown>:0"];
}
subgraph cluster420 {
label="WholeStageCodegen (1)";
179 [labelType="html" label="MapPartitionsRDD [179]<br>count at <unknown>:0"];
}
subgraph cluster425 {
label="mapPartitionsInternal";
180 [labelType="html" label="MapPartitionsRDD [180]<br>count at <unknown>:0"];
}
subgraph cluster426 {
label="mapPartitionsInternal";
181 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#5932)\n +- InMemoryTableScan [brand_context_id#5924, supplier_id#5925, canonical_id#5932, is_primary#5933, entity_name#5926, city#5927, state#5928, country#5929, threshold#5934, create_date#5935], [isnotnull(canonical_id#5932)]\n +- InMemoryRelation [brand_context_id#5924, supplier_id#5925, entity_name#5926, city#5927, state#5928, country#5929, supplier_type#5930, declaring_supplier_id#5931, canonical_id#5932, is_primary#5933, threshold#5934, create_date#5935], 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_primary,\n COALESCE(v.threshold, 0.9) A... [181] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster432 {
label="InMemoryTableScan";
182 [labelType="html" label="MapPartitionsRDD [182]<br>count at <unknown>:0"];
183 [labelType="html" label="MapPartitionsRDD [183]<br>count at <unknown>:0"];
184 [labelType="html" label="MapPartitionsRDD [184]<br>count at <unknown>:0"];
}
subgraph cluster428 {
label="WholeStageCodegen (1)";
185 [labelType="html" label="MapPartitionsRDD [185]<br>count at <unknown>:0"];
}
subgraph cluster427 {
label="Exchange";
186 [labelType="html" label="MapPartitionsRDD [186]<br>count at <unknown>:0"];
}
}
152->153;
153->154;
154->155;
155->176;
176->177;
177->178;
178->179;
179->180;
180->181;
181->182;
182->183;
183->184;
184->185;
185->186;
}
155
181