digraph G {
subgraph clusterstage_889 {
label="Stage 889";
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 cluster7062 {
label="InMemoryTableScan";
3073 [labelType="html" label="MapPartitionsRDD [3073]<br>count at <unknown>:0"];
3074 [labelType="html" label="MapPartitionsRDD [3074]<br>count at <unknown>:0"];
3075 [labelType="html" label="MapPartitionsRDD [3075]<br>count at <unknown>:0"];
}
subgraph cluster7057 {
label="WholeStageCodegen (1)";
3076 [labelType="html" label="MapPartitionsRDD [3076]<br>count at <unknown>:0"];
}
subgraph cluster7063 {
label="mapPartitionsInternal";
3077 [labelType="html" label="MapPartitionsRDD [3077]<br>count at <unknown>:0"];
}
subgraph cluster7064 {
label="mapPartitionsInternal";
3078 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#259127, supplier_id#259128, entity_name#259129, city#259130, state#259131, country#259132, supplier_type#259133, declaring_supplier_id#259134, threshold#259137, create_date#259138]\n +- Filter isnull(canonical_id#259135)\n +- InMemoryTableScan [brand_context_id#259127, canonical_id#259135, city#259130, country#259132, create_date#259138, declaring_supplier_id#259134, entity_name#259129, state#259131, supplier_id#259128, supplier_type#259133, threshold#259137], [isnull(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.sup... [3078] [Cached]<br>count at <unknown>:0"];
}
}
3061->3062;
3062->3063;
3063->3064;
3064->3073;
3073->3074;
3074->3075;
3075->3076;
3076->3077;
3077->3078;
}
3064
3078