digraph G {
subgraph clusterstage_1098 {
label="Stage 1098";
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 cluster8791 {
label="InMemoryTableScan";
3795 [labelType="html" label="MapPartitionsRDD [3795]<br>count at <unknown>:0"];
3796 [labelType="html" label="MapPartitionsRDD [3796]<br>count at <unknown>:0"];
3797 [labelType="html" label="MapPartitionsRDD [3797]<br>count at <unknown>:0"];
}
subgraph cluster8786 {
label="WholeStageCodegen (1)";
3798 [labelType="html" label="MapPartitionsRDD [3798]<br>count at <unknown>:0"];
}
subgraph cluster8792 {
label="mapPartitionsInternal";
3799 [labelType="html" label="MapPartitionsRDD [3799]<br>count at <unknown>:0"];
}
subgraph cluster8793 {
label="mapPartitionsInternal";
3800 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#287266, supplier_id#287267, entity_name#287268, city#287269, state#287270, country#287271, supplier_type#287272, declaring_supplier_id#287273, threshold#287276, create_date#287277]\n +- Filter isnull(canonical_id#287274)\n +- InMemoryTableScan [brand_context_id#287266, canonical_id#287274, city#287269, country#287271, create_date#287277, declaring_supplier_id#287273, entity_name#287268, state#287270, supplier_id#287267, supplier_type#287272, threshold#287276], [isnull(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.sup... [3800] [Cached]<br>count at <unknown>:0"];
}
}
3783->3784;
3784->3785;
3785->3786;
3786->3795;
3795->3796;
3796->3797;
3797->3798;
3798->3799;
3799->3800;
}
3786
3800