digraph G {
subgraph clusterstage_893 {
label="Stage 893";
3061 [labelType="html" label="JDBCRDD [3061]<br>cache at <unknown>:0"];
subgraph cluster7027 {
label="WholeStageCodegen (1)";
3062 [labelType="html" label="MapPartitionsRDD [3062]<br>count at <unknown>:0"];
}
subgraph cluster7029 {
label="mapPartitionsInternal";
3063 [labelType="html" label="MapPartitionsRDD [3063]<br>count at <unknown>:0"];
}
subgraph cluster7030 {
label="mapPartitionsInternal";
3064 [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#259127,supplier_id#259128,entity_name#259129,city#259130,state#259131,country#259132,supplier_type#259133,declaring_supplier_id#259134,canonical_id#259135,is_primary#259136,threshold#259137,create_date#259138] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [3064] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster7087 {
label="InMemoryTableScan";
3085 [labelType="html" label="MapPartitionsRDD [3085]<br>count at <unknown>:0"];
3086 [labelType="html" label="MapPartitionsRDD [3086]<br>count at <unknown>:0"];
3087 [labelType="html" label="MapPartitionsRDD [3087]<br>count at <unknown>:0"];
}
subgraph cluster7083 {
label="WholeStageCodegen (1)";
3088 [labelType="html" label="MapPartitionsRDD [3088]<br>count at <unknown>:0"];
}
subgraph cluster7088 {
label="mapPartitionsInternal";
3089 [labelType="html" label="MapPartitionsRDD [3089]<br>count at <unknown>:0"];
}
subgraph cluster7089 {
label="mapPartitionsInternal";
3090 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#259135)\n +- InMemoryTableScan [brand_context_id#259127, supplier_id#259128, canonical_id#259135, is_primary#259136, entity_name#259129, city#259130, state#259131, country#259132, threshold#259137, create_date#259138], [isnotnull(canonical_id#259135)]\n +- InMemoryRelation [brand_context_id#259127, supplier_id#259128, entity_name#259129, city#259130, state#259131, country#259132, supplier_type#259133, declaring_supplier_id#259134, canonical_id#259135, is_primary#259136, threshold#259137, create_date#259138], 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... [3090] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster7095 {
label="InMemoryTableScan";
3091 [labelType="html" label="MapPartitionsRDD [3091]<br>count at <unknown>:0"];
3092 [labelType="html" label="MapPartitionsRDD [3092]<br>count at <unknown>:0"];
3093 [labelType="html" label="MapPartitionsRDD [3093]<br>count at <unknown>:0"];
}
subgraph cluster7091 {
label="WholeStageCodegen (1)";
3094 [labelType="html" label="MapPartitionsRDD [3094]<br>count at <unknown>:0"];
}
subgraph cluster7090 {
label="Exchange";
3095 [labelType="html" label="MapPartitionsRDD [3095]<br>count at <unknown>:0"];
}
}
3061->3062;
3062->3063;
3063->3064;
3064->3085;
3085->3086;
3086->3087;
3087->3088;
3088->3089;
3089->3090;
3090->3091;
3091->3092;
3092->3093;
3093->3094;
3094->3095;
}
3064
3090