digraph G {
subgraph clusterstage_28644 {
label="Stage 28644";
124380 [labelType="html" label="JDBCRDD [124380]<br>cache at <unknown>:0"];
subgraph cluster310418 {
label="WholeStageCodegen (1)";
124381 [labelType="html" label="MapPartitionsRDD [124381]<br>count at <unknown>:0"];
}
subgraph cluster310420 {
label="mapPartitionsInternal";
124382 [labelType="html" label="MapPartitionsRDD [124382]<br>count at <unknown>:0"];
}
subgraph cluster310421 {
label="mapPartitionsInternal";
124383 [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#12567753,supplier_id#12567754,entity_name#12567755,city#12567756,state#12567757,country#12567758,supplier_type#12567759,declaring_supplier_id#12567760,canonical_id#12567761,is_primary#12567762,threshold#12567763,create_date#12567764] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [124383] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster310478 {
label="InMemoryTableScan";
124404 [labelType="html" label="MapPartitionsRDD [124404]<br>count at <unknown>:0"];
124405 [labelType="html" label="MapPartitionsRDD [124405]<br>count at <unknown>:0"];
124406 [labelType="html" label="MapPartitionsRDD [124406]<br>count at <unknown>:0"];
}
subgraph cluster310474 {
label="WholeStageCodegen (1)";
124407 [labelType="html" label="MapPartitionsRDD [124407]<br>count at <unknown>:0"];
}
subgraph cluster310479 {
label="mapPartitionsInternal";
124408 [labelType="html" label="MapPartitionsRDD [124408]<br>count at <unknown>:0"];
}
subgraph cluster310480 {
label="mapPartitionsInternal";
124409 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#12567761)\n +- InMemoryTableScan [brand_context_id#12567753, supplier_id#12567754, canonical_id#12567761, is_primary#12567762, entity_name#12567755, city#12567756, state#12567757, country#12567758, threshold#12567763, create_date#12567764], [isnotnull(canonical_id#12567761)]\n +- InMemoryRelation [brand_context_id#12567753, supplier_id#12567754, entity_name#12567755, city#12567756, state#12567757, country#12567758, supplier_type#12567759, declaring_supplier_id#12567760, canonical_id#12567761, is_primary#12567762, threshold#12567763, create_date#12567764], 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 ... [124409] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster310486 {
label="InMemoryTableScan";
124410 [labelType="html" label="MapPartitionsRDD [124410]<br>count at <unknown>:0"];
124411 [labelType="html" label="MapPartitionsRDD [124411]<br>count at <unknown>:0"];
124412 [labelType="html" label="MapPartitionsRDD [124412]<br>count at <unknown>:0"];
}
subgraph cluster310482 {
label="WholeStageCodegen (1)";
124413 [labelType="html" label="MapPartitionsRDD [124413]<br>count at <unknown>:0"];
}
subgraph cluster310481 {
label="Exchange";
124414 [labelType="html" label="MapPartitionsRDD [124414]<br>count at <unknown>:0"];
}
}
124380->124381;
124381->124382;
124382->124383;
124383->124404;
124404->124405;
124405->124406;
124406->124407;
124407->124408;
124408->124409;
124409->124410;
124410->124411;
124411->124412;
124412->124413;
124413->124414;
}
124383
124409