digraph G {
subgraph clusterstage_911 {
label="Stage 911";
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 cluster7244 {
label="InMemoryTableScan";
3149 [labelType="html" label="MapPartitionsRDD [3149]<br>count at <unknown>:0"];
3150 [labelType="html" label="MapPartitionsRDD [3150]<br>count at <unknown>:0"];
3151 [labelType="html" label="MapPartitionsRDD [3151]<br>count at <unknown>:0"];
}
subgraph cluster7239 {
label="WholeStageCodegen (1)";
3152 [labelType="html" label="MapPartitionsRDD [3152]<br>count at <unknown>:0"];
}
subgraph cluster7245 {
label="mapPartitionsInternal";
3153 [labelType="html" label="MapPartitionsRDD [3153]<br>count at <unknown>:0"];
}
subgraph cluster7246 {
label="mapPartitionsInternal";
3154 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#262089, supplier_id#262090, entity_name#262091, city#262092, state#262093, country#262094, supplier_type#262095, declaring_supplier_id#262096, threshold#262099, create_date#262100]\n +- Filter isnull(canonical_id#262097)\n +- InMemoryTableScan [brand_context_id#262089, canonical_id#262097, city#262092, country#262094, create_date#262100, declaring_supplier_id#262096, entity_name#262091, state#262093, supplier_id#262090, supplier_type#262095, threshold#262099], [isnull(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.sup... [3154] [Cached]<br>count at <unknown>:0"];
}
}
3137->3138;
3138->3139;
3139->3140;
3140->3149;
3149->3150;
3150->3151;
3151->3152;
3152->3153;
3153->3154;
}
3140
3154