digraph G {
subgraph clusterstage_944 {
label="Stage 944";
3251 [labelType="html" label="JDBCRDD [3251]<br>cache at <unknown>:0"];
subgraph cluster7482 {
label="WholeStageCodegen (1)";
3252 [labelType="html" label="MapPartitionsRDD [3252]<br>count at <unknown>:0"];
}
subgraph cluster7484 {
label="mapPartitionsInternal";
3253 [labelType="html" label="MapPartitionsRDD [3253]<br>count at <unknown>:0"];
}
subgraph cluster7485 {
label="mapPartitionsInternal";
3254 [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#266532,supplier_id#266533,entity_name#266534,city#266535,state#266536,country#266537,supplier_type#266538,declaring_supplier_id#266539,canonical_id#266540,is_primary#266541,threshold#266542,create_date#266543] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [3254] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster7517 {
label="InMemoryTableScan";
3263 [labelType="html" label="MapPartitionsRDD [3263]<br>count at <unknown>:0"];
3264 [labelType="html" label="MapPartitionsRDD [3264]<br>count at <unknown>:0"];
3265 [labelType="html" label="MapPartitionsRDD [3265]<br>count at <unknown>:0"];
}
subgraph cluster7512 {
label="WholeStageCodegen (1)";
3266 [labelType="html" label="MapPartitionsRDD [3266]<br>count at <unknown>:0"];
}
subgraph cluster7518 {
label="mapPartitionsInternal";
3267 [labelType="html" label="MapPartitionsRDD [3267]<br>count at <unknown>:0"];
}
subgraph cluster7519 {
label="mapPartitionsInternal";
3268 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#266532, supplier_id#266533, entity_name#266534, city#266535, state#266536, country#266537, supplier_type#266538, declaring_supplier_id#266539, threshold#266542, create_date#266543]\n +- Filter isnull(canonical_id#266540)\n +- InMemoryTableScan [brand_context_id#266532, canonical_id#266540, city#266535, country#266537, create_date#266543, declaring_supplier_id#266539, entity_name#266534, state#266536, supplier_id#266533, supplier_type#266538, threshold#266542], [isnull(canonical_id#266540)]\n +- InMemoryRelation [brand_context_id#266532, supplier_id#266533, entity_name#266534, city#266535, state#266536, country#266537, supplier_type#266538, declaring_supplier_id#266539, canonical_id#266540, is_primary#266541, threshold#266542, create_date#266543], StorageLevel(disk, memory, deserialized, 1 replicas)\n +- *(1) Scan JDBCRelation((\n SELECT DISTINCT\n v.brand_context_id,\n v.sup... [3268] [Cached]<br>count at <unknown>:0"];
}
}
3251->3252;
3252->3253;
3253->3254;
3254->3263;
3263->3264;
3264->3265;
3265->3266;
3266->3267;
3267->3268;
}
3254
3268