digraph G {
subgraph clusterstage_915 {
label="Stage 915";
3137 [labelType="html" label="JDBCRDD [3137]<br>cache at <unknown>:0"];
subgraph cluster7209 {
label="WholeStageCodegen (1)";
3138 [labelType="html" label="MapPartitionsRDD [3138]<br>count at <unknown>:0"];
}
subgraph cluster7211 {
label="mapPartitionsInternal";
3139 [labelType="html" label="MapPartitionsRDD [3139]<br>count at <unknown>:0"];
}
subgraph cluster7212 {
label="mapPartitionsInternal";
3140 [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#262089,supplier_id#262090,entity_name#262091,city#262092,state#262093,country#262094,supplier_type#262095,declaring_supplier_id#262096,canonical_id#262097,is_primary#262098,threshold#262099,create_date#262100] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [3140] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster7269 {
label="InMemoryTableScan";
3161 [labelType="html" label="MapPartitionsRDD [3161]<br>count at <unknown>:0"];
3162 [labelType="html" label="MapPartitionsRDD [3162]<br>count at <unknown>:0"];
3163 [labelType="html" label="MapPartitionsRDD [3163]<br>count at <unknown>:0"];
}
subgraph cluster7265 {
label="WholeStageCodegen (1)";
3164 [labelType="html" label="MapPartitionsRDD [3164]<br>count at <unknown>:0"];
}
subgraph cluster7270 {
label="mapPartitionsInternal";
3165 [labelType="html" label="MapPartitionsRDD [3165]<br>count at <unknown>:0"];
}
subgraph cluster7271 {
label="mapPartitionsInternal";
3166 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#262097)\n +- InMemoryTableScan [brand_context_id#262089, supplier_id#262090, canonical_id#262097, is_primary#262098, entity_name#262091, city#262092, state#262093, country#262094, threshold#262099, create_date#262100], [isnotnull(canonical_id#262097)]\n +- InMemoryRelation [brand_context_id#262089, supplier_id#262090, entity_name#262091, city#262092, state#262093, country#262094, supplier_type#262095, declaring_supplier_id#262096, canonical_id#262097, is_primary#262098, threshold#262099, create_date#262100], 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... [3166] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster7277 {
label="InMemoryTableScan";
3167 [labelType="html" label="MapPartitionsRDD [3167]<br>count at <unknown>:0"];
3168 [labelType="html" label="MapPartitionsRDD [3168]<br>count at <unknown>:0"];
3169 [labelType="html" label="MapPartitionsRDD [3169]<br>count at <unknown>:0"];
}
subgraph cluster7273 {
label="WholeStageCodegen (1)";
3170 [labelType="html" label="MapPartitionsRDD [3170]<br>count at <unknown>:0"];
}
subgraph cluster7272 {
label="Exchange";
3171 [labelType="html" label="MapPartitionsRDD [3171]<br>count at <unknown>:0"];
}
}
3137->3138;
3138->3139;
3139->3140;
3140->3161;
3161->3162;
3162->3163;
3163->3164;
3164->3165;
3165->3166;
3166->3167;
3167->3168;
3168->3169;
3169->3170;
3170->3171;
}
3140
3166