digraph G {
subgraph clusterstage_1102 {
label="Stage 1102";
3783 [labelType="html" label="JDBCRDD [3783]<br>cache at <unknown>:0"];
subgraph cluster8756 {
label="WholeStageCodegen (1)";
3784 [labelType="html" label="MapPartitionsRDD [3784]<br>count at <unknown>:0"];
}
subgraph cluster8758 {
label="mapPartitionsInternal";
3785 [labelType="html" label="MapPartitionsRDD [3785]<br>count at <unknown>:0"];
}
subgraph cluster8759 {
label="mapPartitionsInternal";
3786 [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#287266,supplier_id#287267,entity_name#287268,city#287269,state#287270,country#287271,supplier_type#287272,declaring_supplier_id#287273,canonical_id#287274,is_primary#287275,threshold#287276,create_date#287277] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [3786] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster8816 {
label="InMemoryTableScan";
3807 [labelType="html" label="MapPartitionsRDD [3807]<br>count at <unknown>:0"];
3808 [labelType="html" label="MapPartitionsRDD [3808]<br>count at <unknown>:0"];
3809 [labelType="html" label="MapPartitionsRDD [3809]<br>count at <unknown>:0"];
}
subgraph cluster8812 {
label="WholeStageCodegen (1)";
3810 [labelType="html" label="MapPartitionsRDD [3810]<br>count at <unknown>:0"];
}
subgraph cluster8817 {
label="mapPartitionsInternal";
3811 [labelType="html" label="MapPartitionsRDD [3811]<br>count at <unknown>:0"];
}
subgraph cluster8818 {
label="mapPartitionsInternal";
3812 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#287274)\n +- InMemoryTableScan [brand_context_id#287266, supplier_id#287267, canonical_id#287274, is_primary#287275, entity_name#287268, city#287269, state#287270, country#287271, threshold#287276, create_date#287277], [isnotnull(canonical_id#287274)]\n +- InMemoryRelation [brand_context_id#287266, supplier_id#287267, entity_name#287268, city#287269, state#287270, country#287271, supplier_type#287272, declaring_supplier_id#287273, canonical_id#287274, is_primary#287275, threshold#287276, create_date#287277], 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... [3812] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster8824 {
label="InMemoryTableScan";
3813 [labelType="html" label="MapPartitionsRDD [3813]<br>count at <unknown>:0"];
3814 [labelType="html" label="MapPartitionsRDD [3814]<br>count at <unknown>:0"];
3815 [labelType="html" label="MapPartitionsRDD [3815]<br>count at <unknown>:0"];
}
subgraph cluster8820 {
label="WholeStageCodegen (1)";
3816 [labelType="html" label="MapPartitionsRDD [3816]<br>count at <unknown>:0"];
}
subgraph cluster8819 {
label="Exchange";
3817 [labelType="html" label="MapPartitionsRDD [3817]<br>count at <unknown>:0"];
}
}
3783->3784;
3784->3785;
3785->3786;
3786->3807;
3807->3808;
3808->3809;
3809->3810;
3810->3811;
3811->3812;
3812->3813;
3813->3814;
3814->3815;
3815->3816;
3816->3817;
}
3786
3812