digraph G {
subgraph clusterstage_1406 {
label="Stage 1406";
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 cluster11339 {
label="InMemoryTableScan";
4859 [labelType="html" label="MapPartitionsRDD [4859]<br>count at <unknown>:0"];
4860 [labelType="html" label="MapPartitionsRDD [4860]<br>count at <unknown>:0"];
4861 [labelType="html" label="MapPartitionsRDD [4861]<br>count at <unknown>:0"];
}
subgraph cluster11334 {
label="WholeStageCodegen (1)";
4862 [labelType="html" label="MapPartitionsRDD [4862]<br>count at <unknown>:0"];
}
subgraph cluster11340 {
label="mapPartitionsInternal";
4863 [labelType="html" label="MapPartitionsRDD [4863]<br>count at <unknown>:0"];
}
subgraph cluster11341 {
label="mapPartitionsInternal";
4864 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#328734, supplier_id#328735, entity_name#328736, city#328737, state#328738, country#328739, supplier_type#328740, declaring_supplier_id#328741, threshold#328744, create_date#328745]\n +- Filter isnull(canonical_id#328742)\n +- InMemoryTableScan [brand_context_id#328734, canonical_id#328742, city#328737, country#328739, create_date#328745, declaring_supplier_id#328741, entity_name#328736, state#328738, supplier_id#328735, supplier_type#328740, threshold#328744], [isnull(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.sup... [4864] [Cached]<br>count at <unknown>:0"];
}
}
4847->4848;
4848->4849;
4849->4850;
4850->4859;
4859->4860;
4860->4861;
4861->4862;
4862->4863;
4863->4864;
}
4850
4864