digraph G {
subgraph clusterstage_44035 {
label="Stage 44035";
191177 [labelType="html" label="JDBCRDD [191177]<br>cache at <unknown>:0"];
subgraph cluster450789 {
label="WholeStageCodegen (1)";
191178 [labelType="html" label="MapPartitionsRDD [191178]<br>count at <unknown>:0"];
}
subgraph cluster450791 {
label="mapPartitionsInternal";
191179 [labelType="html" label="MapPartitionsRDD [191179]<br>count at <unknown>:0"];
}
subgraph cluster450792 {
label="mapPartitionsInternal";
191180 [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#17293773,supplier_id#17293774,entity_name#17293775,city#17293776,state#17293777,country#17293778,supplier_type#17293779,declaring_supplier_id#17293780,canonical_id#17293781,is_primary#17293782,threshold#17293783,create_date#17293784] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [191180] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster450849 {
label="InMemoryTableScan";
191201 [labelType="html" label="MapPartitionsRDD [191201]<br>count at <unknown>:0"];
191202 [labelType="html" label="MapPartitionsRDD [191202]<br>count at <unknown>:0"];
191203 [labelType="html" label="MapPartitionsRDD [191203]<br>count at <unknown>:0"];
}
subgraph cluster450845 {
label="WholeStageCodegen (1)";
191204 [labelType="html" label="MapPartitionsRDD [191204]<br>count at <unknown>:0"];
}
subgraph cluster450850 {
label="mapPartitionsInternal";
191205 [labelType="html" label="MapPartitionsRDD [191205]<br>count at <unknown>:0"];
}
subgraph cluster450851 {
label="mapPartitionsInternal";
191206 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#17293781)\n +- InMemoryTableScan [brand_context_id#17293773, supplier_id#17293774, canonical_id#17293781, is_primary#17293782, entity_name#17293775, city#17293776, state#17293777, country#17293778, threshold#17293783, create_date#17293784], [isnotnull(canonical_id#17293781)]\n +- InMemoryRelation [brand_context_id#17293773, supplier_id#17293774, entity_name#17293775, city#17293776, state#17293777, country#17293778, supplier_type#17293779, declaring_supplier_id#17293780, canonical_id#17293781, is_primary#17293782, threshold#17293783, create_date#17293784], 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 ... [191206] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster450857 {
label="InMemoryTableScan";
191207 [labelType="html" label="MapPartitionsRDD [191207]<br>count at <unknown>:0"];
191208 [labelType="html" label="MapPartitionsRDD [191208]<br>count at <unknown>:0"];
191209 [labelType="html" label="MapPartitionsRDD [191209]<br>count at <unknown>:0"];
}
subgraph cluster450853 {
label="WholeStageCodegen (1)";
191210 [labelType="html" label="MapPartitionsRDD [191210]<br>count at <unknown>:0"];
}
subgraph cluster450852 {
label="Exchange";
191211 [labelType="html" label="MapPartitionsRDD [191211]<br>count at <unknown>:0"];
}
}
191177->191178;
191178->191179;
191179->191180;
191180->191201;
191201->191202;
191202->191203;
191203->191204;
191204->191205;
191205->191206;
191206->191207;
191207->191208;
191208->191209;
191209->191210;
191210->191211;
}
191180
191206