digraph G {
subgraph clusterstage_2595 {
label="Stage 2595";
9297 [labelType="html" label="JDBCRDD [9297]<br>cache at <unknown>:0"];
subgraph cluster21206 {
label="WholeStageCodegen (1)";
9298 [labelType="html" label="MapPartitionsRDD [9298]<br>count at <unknown>:0"];
}
subgraph cluster21208 {
label="mapPartitionsInternal";
9299 [labelType="html" label="MapPartitionsRDD [9299]<br>count at <unknown>:0"];
}
subgraph cluster21209 {
label="mapPartitionsInternal";
9300 [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#824734,supplier_id#824735,entity_name#824736,city#824737,state#824738,country#824739,supplier_type#824740,declaring_supplier_id#824741,canonical_id#824742,is_primary#824743,threshold#824744,create_date#824745] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [9300] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster21241 {
label="InMemoryTableScan";
9309 [labelType="html" label="MapPartitionsRDD [9309]<br>count at <unknown>:0"];
9310 [labelType="html" label="MapPartitionsRDD [9310]<br>count at <unknown>:0"];
9311 [labelType="html" label="MapPartitionsRDD [9311]<br>count at <unknown>:0"];
}
subgraph cluster21236 {
label="WholeStageCodegen (1)";
9312 [labelType="html" label="MapPartitionsRDD [9312]<br>count at <unknown>:0"];
}
subgraph cluster21242 {
label="mapPartitionsInternal";
9313 [labelType="html" label="MapPartitionsRDD [9313]<br>count at <unknown>:0"];
}
subgraph cluster21243 {
label="mapPartitionsInternal";
9314 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#824734, supplier_id#824735, entity_name#824736, city#824737, state#824738, country#824739, supplier_type#824740, declaring_supplier_id#824741, threshold#824744, create_date#824745]\n +- Filter isnull(canonical_id#824742)\n +- InMemoryTableScan [brand_context_id#824734, canonical_id#824742, city#824737, country#824739, create_date#824745, declaring_supplier_id#824741, entity_name#824736, state#824738, supplier_id#824735, supplier_type#824740, threshold#824744], [isnull(canonical_id#824742)]\n +- InMemoryRelation [brand_context_id#824734, supplier_id#824735, entity_name#824736, city#824737, state#824738, country#824739, supplier_type#824740, declaring_supplier_id#824741, canonical_id#824742, is_primary#824743, threshold#824744, create_date#824745], StorageLevel(disk, memory, deserialized, 1 replicas)\n +- *(1) Scan JDBCRelation((\n SELECT DISTINCT\n v.brand_context_id,\n v.sup... [9314] [Cached]<br>count at <unknown>:0"];
}
}
9297->9298;
9298->9299;
9299->9300;
9300->9309;
9309->9310;
9310->9311;
9311->9312;
9312->9313;
9313->9314;
}
9300
9314