digraph G {
subgraph clusterstage_44024 {
label="Stage 44024";
191139 [labelType="html" label="JDBCRDD [191139]<br>cache at <unknown>:0"];
subgraph cluster450698 {
label="WholeStageCodegen (1)";
191140 [labelType="html" label="MapPartitionsRDD [191140]<br>count at <unknown>:0"];
}
subgraph cluster450700 {
label="mapPartitionsInternal";
191141 [labelType="html" label="MapPartitionsRDD [191141]<br>count at <unknown>:0"];
}
subgraph cluster450701 {
label="mapPartitionsInternal";
191142 [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#17292292,supplier_id#17292293,entity_name#17292294,city#17292295,state#17292296,country#17292297,supplier_type#17292298,declaring_supplier_id#17292299,canonical_id#17292300,is_primary#17292301,threshold#17292302,create_date#17292303] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [191142] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster450758 {
label="InMemoryTableScan";
191163 [labelType="html" label="MapPartitionsRDD [191163]<br>count at <unknown>:0"];
191164 [labelType="html" label="MapPartitionsRDD [191164]<br>count at <unknown>:0"];
191165 [labelType="html" label="MapPartitionsRDD [191165]<br>count at <unknown>:0"];
}
subgraph cluster450754 {
label="WholeStageCodegen (1)";
191166 [labelType="html" label="MapPartitionsRDD [191166]<br>count at <unknown>:0"];
}
subgraph cluster450759 {
label="mapPartitionsInternal";
191167 [labelType="html" label="MapPartitionsRDD [191167]<br>count at <unknown>:0"];
}
subgraph cluster450760 {
label="mapPartitionsInternal";
191168 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#17292300)\n +- InMemoryTableScan [brand_context_id#17292292, supplier_id#17292293, canonical_id#17292300, is_primary#17292301, entity_name#17292294, city#17292295, state#17292296, country#17292297, threshold#17292302, create_date#17292303], [isnotnull(canonical_id#17292300)]\n +- InMemoryRelation [brand_context_id#17292292, supplier_id#17292293, entity_name#17292294, city#17292295, state#17292296, country#17292297, supplier_type#17292298, declaring_supplier_id#17292299, canonical_id#17292300, is_primary#17292301, threshold#17292302, create_date#17292303], 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 ... [191168] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster450766 {
label="InMemoryTableScan";
191169 [labelType="html" label="MapPartitionsRDD [191169]<br>count at <unknown>:0"];
191170 [labelType="html" label="MapPartitionsRDD [191170]<br>count at <unknown>:0"];
191171 [labelType="html" label="MapPartitionsRDD [191171]<br>count at <unknown>:0"];
}
subgraph cluster450762 {
label="WholeStageCodegen (1)";
191172 [labelType="html" label="MapPartitionsRDD [191172]<br>count at <unknown>:0"];
}
subgraph cluster450761 {
label="Exchange";
191173 [labelType="html" label="MapPartitionsRDD [191173]<br>count at <unknown>:0"];
}
}
191139->191140;
191140->191141;
191141->191142;
191142->191163;
191163->191164;
191164->191165;
191165->191166;
191166->191167;
191167->191168;
191168->191169;
191169->191170;
191170->191171;
191171->191172;
191172->191173;
}
191142
191168