digraph G {
subgraph clusterstage_81 {
label="Stage 81";
266 [labelType="html" label="JDBCRDD [266]<br>cache at <unknown>:0"];
subgraph cluster637 {
label="WholeStageCodegen (1)";
267 [labelType="html" label="MapPartitionsRDD [267]<br>count at <unknown>:0"];
}
subgraph cluster639 {
label="mapPartitionsInternal";
268 [labelType="html" label="MapPartitionsRDD [268]<br>count at <unknown>:0"];
}
subgraph cluster640 {
label="mapPartitionsInternal";
269 [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#10367,supplier_id#10368,entity_name#10369,city#10370,state#10371,country#10372,supplier_type#10373,declaring_supplier_id#10374,canonical_id#10375,is_primary#10376,threshold#10377,create_date#10378] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [269] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster672 {
label="InMemoryTableScan";
278 [labelType="html" label="MapPartitionsRDD [278]<br>count at <unknown>:0"];
279 [labelType="html" label="MapPartitionsRDD [279]<br>count at <unknown>:0"];
280 [labelType="html" label="MapPartitionsRDD [280]<br>count at <unknown>:0"];
}
subgraph cluster667 {
label="WholeStageCodegen (1)";
281 [labelType="html" label="MapPartitionsRDD [281]<br>count at <unknown>:0"];
}
subgraph cluster673 {
label="mapPartitionsInternal";
282 [labelType="html" label="MapPartitionsRDD [282]<br>count at <unknown>:0"];
}
subgraph cluster674 {
label="mapPartitionsInternal";
283 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#10367, supplier_id#10368, entity_name#10369, city#10370, state#10371, country#10372, supplier_type#10373, declaring_supplier_id#10374, threshold#10377, create_date#10378]\n +- Filter isnull(canonical_id#10375)\n +- InMemoryTableScan [brand_context_id#10367, canonical_id#10375, city#10370, country#10372, create_date#10378, declaring_supplier_id#10374, entity_name#10369, state#10371, supplier_id#10368, supplier_type#10373, threshold#10377], [isnull(canonical_id#10375)]\n +- InMemoryRelation [brand_context_id#10367, supplier_id#10368, entity_name#10369, city#10370, state#10371, country#10372, supplier_type#10373, declaring_supplier_id#10374, canonical_id#10375, is_primary#10376, threshold#10377, create_date#10378], 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_... [283] [Cached]<br>count at <unknown>:0"];
}
}
266->267;
267->268;
268->269;
269->278;
278->279;
279->280;
280->281;
281->282;
282->283;
}
269
283