digraph G {
subgraph clusterstage_3318 {
label="Stage 3318";
11788 [labelType="html" label="JDBCRDD [11788]<br>cache at <unknown>:0"];
subgraph cluster26868 {
label="WholeStageCodegen (1)";
11789 [labelType="html" label="MapPartitionsRDD [11789]<br>count at <unknown>:0"];
}
subgraph cluster26870 {
label="mapPartitionsInternal";
11790 [labelType="html" label="MapPartitionsRDD [11790]<br>count at <unknown>:0"];
}
subgraph cluster26871 {
label="mapPartitionsInternal";
11791 [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#1061646,supplier_id#1061647,entity_name#1061648,city#1061649,state#1061650,country#1061651,supplier_type#1061652,declaring_supplier_id#1061653,canonical_id#1061654,is_primary#1061655,threshold#1061656,create_date#1061657] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [11791] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster26928 {
label="InMemoryTableScan";
11812 [labelType="html" label="MapPartitionsRDD [11812]<br>count at <unknown>:0"];
11813 [labelType="html" label="MapPartitionsRDD [11813]<br>count at <unknown>:0"];
11814 [labelType="html" label="MapPartitionsRDD [11814]<br>count at <unknown>:0"];
}
subgraph cluster26924 {
label="WholeStageCodegen (1)";
11815 [labelType="html" label="MapPartitionsRDD [11815]<br>count at <unknown>:0"];
}
subgraph cluster26929 {
label="mapPartitionsInternal";
11816 [labelType="html" label="MapPartitionsRDD [11816]<br>count at <unknown>:0"];
}
subgraph cluster26930 {
label="mapPartitionsInternal";
11817 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#1061654)\n +- InMemoryTableScan [brand_context_id#1061646, supplier_id#1061647, canonical_id#1061654, is_primary#1061655, entity_name#1061648, city#1061649, state#1061650, country#1061651, threshold#1061656, create_date#1061657], [isnotnull(canonical_id#1061654)]\n +- InMemoryRelation [brand_context_id#1061646, supplier_id#1061647, entity_name#1061648, city#1061649, state#1061650, country#1061651, supplier_type#1061652, declaring_supplier_id#1061653, canonical_id#1061654, is_primary#1061655, threshold#1061656, create_date#1061657], 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 ... [11817] [Cached]<br>count at <unknown>:0"];
}
}
11788->11789;
11789->11790;
11790->11791;
11791->11812;
11812->11813;
11813->11814;
11814->11815;
11815->11816;
11816->11817;
}
11791
11817