digraph G {
subgraph clusterstage_1090 {
label="Stage 1090";
3745 [labelType="html" label="JDBCRDD [3745]<br>cache at <unknown>:0"];
subgraph cluster8665 {
label="WholeStageCodegen (1)";
3746 [labelType="html" label="MapPartitionsRDD [3746]<br>count at <unknown>:0"];
}
subgraph cluster8667 {
label="mapPartitionsInternal";
3747 [labelType="html" label="MapPartitionsRDD [3747]<br>count at <unknown>:0"];
}
subgraph cluster8668 {
label="mapPartitionsInternal";
3748 [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#285785,supplier_id#285786,entity_name#285787,city#285788,state#285789,country#285790,supplier_type#285791,declaring_supplier_id#285792,canonical_id#285793,is_primary#285794,threshold#285795,create_date#285796] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [3748] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster8725 {
label="InMemoryTableScan";
3769 [labelType="html" label="MapPartitionsRDD [3769]<br>count at <unknown>:0"];
3770 [labelType="html" label="MapPartitionsRDD [3770]<br>count at <unknown>:0"];
3771 [labelType="html" label="MapPartitionsRDD [3771]<br>count at <unknown>:0"];
}
subgraph cluster8721 {
label="WholeStageCodegen (1)";
3772 [labelType="html" label="MapPartitionsRDD [3772]<br>count at <unknown>:0"];
}
subgraph cluster8726 {
label="mapPartitionsInternal";
3773 [labelType="html" label="MapPartitionsRDD [3773]<br>count at <unknown>:0"];
}
subgraph cluster8727 {
label="mapPartitionsInternal";
3774 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#285793)\n +- InMemoryTableScan [brand_context_id#285785, supplier_id#285786, canonical_id#285793, is_primary#285794, entity_name#285787, city#285788, state#285789, country#285790, threshold#285795, create_date#285796], [isnotnull(canonical_id#285793)]\n +- InMemoryRelation [brand_context_id#285785, supplier_id#285786, entity_name#285787, city#285788, state#285789, country#285790, supplier_type#285791, declaring_supplier_id#285792, canonical_id#285793, is_primary#285794, threshold#285795, create_date#285796], 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 v.is_prima... [3774] [Cached]<br>count at <unknown>:0"];
}
}
3745->3746;
3746->3747;
3747->3748;
3748->3769;
3769->3770;
3770->3771;
3771->3772;
3772->3773;
3773->3774;
}
3748
3774