digraph G {
subgraph clusterstage_2606 {
label="Stage 2606";
9335 [labelType="html" label="JDBCRDD [9335]<br>cache at <unknown>:0"];
subgraph cluster21297 {
label="WholeStageCodegen (1)";
9336 [labelType="html" label="MapPartitionsRDD [9336]<br>count at <unknown>:0"];
}
subgraph cluster21299 {
label="mapPartitionsInternal";
9337 [labelType="html" label="MapPartitionsRDD [9337]<br>count at <unknown>:0"];
}
subgraph cluster21300 {
label="mapPartitionsInternal";
9338 [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#826215,supplier_id#826216,entity_name#826217,city#826218,state#826219,country#826220,supplier_type#826221,declaring_supplier_id#826222,canonical_id#826223,is_primary#826224,threshold#826225,create_date#826226] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [9338] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster21332 {
label="InMemoryTableScan";
9347 [labelType="html" label="MapPartitionsRDD [9347]<br>count at <unknown>:0"];
9348 [labelType="html" label="MapPartitionsRDD [9348]<br>count at <unknown>:0"];
9349 [labelType="html" label="MapPartitionsRDD [9349]<br>count at <unknown>:0"];
}
subgraph cluster21327 {
label="WholeStageCodegen (1)";
9350 [labelType="html" label="MapPartitionsRDD [9350]<br>count at <unknown>:0"];
}
subgraph cluster21333 {
label="mapPartitionsInternal";
9351 [labelType="html" label="MapPartitionsRDD [9351]<br>count at <unknown>:0"];
}
subgraph cluster21334 {
label="mapPartitionsInternal";
9352 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#826215, supplier_id#826216, entity_name#826217, city#826218, state#826219, country#826220, supplier_type#826221, declaring_supplier_id#826222, threshold#826225, create_date#826226]\n +- Filter isnull(canonical_id#826223)\n +- InMemoryTableScan [brand_context_id#826215, canonical_id#826223, city#826218, country#826220, create_date#826226, declaring_supplier_id#826222, entity_name#826217, state#826219, supplier_id#826216, supplier_type#826221, threshold#826225], [isnull(canonical_id#826223)]\n +- InMemoryRelation [brand_context_id#826215, supplier_id#826216, entity_name#826217, city#826218, state#826219, country#826220, supplier_type#826221, declaring_supplier_id#826222, canonical_id#826223, is_primary#826224, threshold#826225, create_date#826226], StorageLevel(disk, memory, deserialized, 1 replicas)\n +- *(1) Scan JDBCRelation((\n SELECT DISTINCT\n v.brand_context_id,\n v.sup... [9352] [Cached]<br>count at <unknown>:0"];
}
}
9335->9336;
9336->9337;
9337->9338;
9338->9347;
9347->9348;
9348->9349;
9349->9350;
9350->9351;
9351->9352;
}
9338
9352