digraph G {
subgraph clusterstage_1417 {
label="Stage 1417";
4885 [labelType="html" label="JDBCRDD [4885]<br>cache at <unknown>:0"];
subgraph cluster11395 {
label="WholeStageCodegen (1)";
4886 [labelType="html" label="MapPartitionsRDD [4886]<br>count at <unknown>:0"];
}
subgraph cluster11397 {
label="mapPartitionsInternal";
4887 [labelType="html" label="MapPartitionsRDD [4887]<br>count at <unknown>:0"];
}
subgraph cluster11398 {
label="mapPartitionsInternal";
4888 [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#330215,supplier_id#330216,entity_name#330217,city#330218,state#330219,country#330220,supplier_type#330221,declaring_supplier_id#330222,canonical_id#330223,is_primary#330224,threshold#330225,create_date#330226] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [4888] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster11430 {
label="InMemoryTableScan";
4897 [labelType="html" label="MapPartitionsRDD [4897]<br>count at <unknown>:0"];
4898 [labelType="html" label="MapPartitionsRDD [4898]<br>count at <unknown>:0"];
4899 [labelType="html" label="MapPartitionsRDD [4899]<br>count at <unknown>:0"];
}
subgraph cluster11425 {
label="WholeStageCodegen (1)";
4900 [labelType="html" label="MapPartitionsRDD [4900]<br>count at <unknown>:0"];
}
subgraph cluster11431 {
label="mapPartitionsInternal";
4901 [labelType="html" label="MapPartitionsRDD [4901]<br>count at <unknown>:0"];
}
subgraph cluster11432 {
label="mapPartitionsInternal";
4902 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#330215, supplier_id#330216, entity_name#330217, city#330218, state#330219, country#330220, supplier_type#330221, declaring_supplier_id#330222, threshold#330225, create_date#330226]\n +- Filter isnull(canonical_id#330223)\n +- InMemoryTableScan [brand_context_id#330215, canonical_id#330223, city#330218, country#330220, create_date#330226, declaring_supplier_id#330222, entity_name#330217, state#330219, supplier_id#330216, supplier_type#330221, threshold#330225], [isnull(canonical_id#330223)]\n +- InMemoryRelation [brand_context_id#330215, supplier_id#330216, entity_name#330217, city#330218, state#330219, country#330220, supplier_type#330221, declaring_supplier_id#330222, canonical_id#330223, is_primary#330224, threshold#330225, create_date#330226], StorageLevel(disk, memory, deserialized, 1 replicas)\n +- *(1) Scan JDBCRelation((\n SELECT DISTINCT\n v.brand_context_id,\n v.sup... [4902] [Cached]<br>count at <unknown>:0"];
}
}
4885->4886;
4886->4887;
4887->4888;
4888->4897;
4897->4898;
4898->4899;
4899->4900;
4900->4901;
4901->4902;
}
4888
4902