digraph G {
subgraph clusterstage_1410 {
label="Stage 1410";
4847 [labelType="html" label="JDBCRDD [4847]<br>cache at <unknown>:0"];
subgraph cluster11304 {
label="WholeStageCodegen (1)";
4848 [labelType="html" label="MapPartitionsRDD [4848]<br>count at <unknown>:0"];
}
subgraph cluster11306 {
label="mapPartitionsInternal";
4849 [labelType="html" label="MapPartitionsRDD [4849]<br>count at <unknown>:0"];
}
subgraph cluster11307 {
label="mapPartitionsInternal";
4850 [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#328734,supplier_id#328735,entity_name#328736,city#328737,state#328738,country#328739,supplier_type#328740,declaring_supplier_id#328741,canonical_id#328742,is_primary#328743,threshold#328744,create_date#328745] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [4850] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster11364 {
label="InMemoryTableScan";
4871 [labelType="html" label="MapPartitionsRDD [4871]<br>count at <unknown>:0"];
4872 [labelType="html" label="MapPartitionsRDD [4872]<br>count at <unknown>:0"];
4873 [labelType="html" label="MapPartitionsRDD [4873]<br>count at <unknown>:0"];
}
subgraph cluster11360 {
label="WholeStageCodegen (1)";
4874 [labelType="html" label="MapPartitionsRDD [4874]<br>count at <unknown>:0"];
}
subgraph cluster11365 {
label="mapPartitionsInternal";
4875 [labelType="html" label="MapPartitionsRDD [4875]<br>count at <unknown>:0"];
}
subgraph cluster11366 {
label="mapPartitionsInternal";
4876 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#328742)\n +- InMemoryTableScan [brand_context_id#328734, supplier_id#328735, canonical_id#328742, is_primary#328743, entity_name#328736, city#328737, state#328738, country#328739, threshold#328744, create_date#328745], [isnotnull(canonical_id#328742)]\n +- InMemoryRelation [brand_context_id#328734, supplier_id#328735, entity_name#328736, city#328737, state#328738, country#328739, supplier_type#328740, declaring_supplier_id#328741, canonical_id#328742, is_primary#328743, threshold#328744, create_date#328745], 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 v.canonical_id,\n v.is_prima... [4876] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster11372 {
label="InMemoryTableScan";
4877 [labelType="html" label="MapPartitionsRDD [4877]<br>count at <unknown>:0"];
4878 [labelType="html" label="MapPartitionsRDD [4878]<br>count at <unknown>:0"];
4879 [labelType="html" label="MapPartitionsRDD [4879]<br>count at <unknown>:0"];
}
subgraph cluster11368 {
label="WholeStageCodegen (1)";
4880 [labelType="html" label="MapPartitionsRDD [4880]<br>count at <unknown>:0"];
}
subgraph cluster11367 {
label="Exchange";
4881 [labelType="html" label="MapPartitionsRDD [4881]<br>count at <unknown>:0"];
}
}
4847->4848;
4848->4849;
4849->4850;
4850->4871;
4871->4872;
4872->4873;
4873->4874;
4874->4875;
4875->4876;
4876->4877;
4877->4878;
4878->4879;
4879->4880;
4880->4881;
}
4850
4876