digraph G {
subgraph clusterstage_48 {
label="Stage 48";
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 cluster399 {
label="InMemoryTableScan";
164 [labelType="html" label="MapPartitionsRDD [164]<br>count at <unknown>:0"];
165 [labelType="html" label="MapPartitionsRDD [165]<br>count at <unknown>:0"];
166 [labelType="html" label="MapPartitionsRDD [166]<br>count at <unknown>:0"];
}
subgraph cluster394 {
label="WholeStageCodegen (1)";
167 [labelType="html" label="MapPartitionsRDD [167]<br>count at <unknown>:0"];
}
subgraph cluster400 {
label="mapPartitionsInternal";
168 [labelType="html" label="MapPartitionsRDD [168]<br>count at <unknown>:0"];
}
subgraph cluster401 {
label="mapPartitionsInternal";
169 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#5924, supplier_id#5925, entity_name#5926, city#5927, state#5928, country#5929, supplier_type#5930, declaring_supplier_id#5931, threshold#5934, create_date#5935]\n +- Filter isnull(canonical_id#5932)\n +- InMemoryTableScan [brand_context_id#5924, canonical_id#5932, city#5927, country#5929, create_date#5935, declaring_supplier_id#5931, entity_name#5926, state#5928, supplier_id#5925, supplier_type#5930, threshold#5934], [isnull(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 ... [169] [Cached]<br>count at <unknown>:0"];
}
}
152->153;
153->154;
154->155;
155->164;
164->165;
165->166;
166->167;
167->168;
168->169;
}
155
169