digraph G {
subgraph clusterstage_1167 {
label="Stage 1167";
4011 [labelType="html" label="JDBCRDD [4011]<br>cache at <unknown>:0"];
subgraph cluster9302 {
label="WholeStageCodegen (1)";
4012 [labelType="html" label="MapPartitionsRDD [4012]<br>count at <unknown>:0"];
}
subgraph cluster9304 {
label="mapPartitionsInternal";
4013 [labelType="html" label="MapPartitionsRDD [4013]<br>count at <unknown>:0"];
}
subgraph cluster9305 {
label="mapPartitionsInternal";
4014 [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#296152,supplier_id#296153,entity_name#296154,city#296155,state#296156,country#296157,supplier_type#296158,declaring_supplier_id#296159,canonical_id#296160,is_primary#296161,threshold#296162,create_date#296163] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [4014] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster9362 {
label="InMemoryTableScan";
4035 [labelType="html" label="MapPartitionsRDD [4035]<br>count at <unknown>:0"];
4036 [labelType="html" label="MapPartitionsRDD [4036]<br>count at <unknown>:0"];
4037 [labelType="html" label="MapPartitionsRDD [4037]<br>count at <unknown>:0"];
}
subgraph cluster9358 {
label="WholeStageCodegen (1)";
4038 [labelType="html" label="MapPartitionsRDD [4038]<br>count at <unknown>:0"];
}
subgraph cluster9363 {
label="mapPartitionsInternal";
4039 [labelType="html" label="MapPartitionsRDD [4039]<br>count at <unknown>:0"];
}
subgraph cluster9364 {
label="mapPartitionsInternal";
4040 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#296160)\n +- InMemoryTableScan [brand_context_id#296152, supplier_id#296153, canonical_id#296160, is_primary#296161, entity_name#296154, city#296155, state#296156, country#296157, threshold#296162, create_date#296163], [isnotnull(canonical_id#296160)]\n +- InMemoryRelation [brand_context_id#296152, supplier_id#296153, entity_name#296154, city#296155, state#296156, country#296157, supplier_type#296158, declaring_supplier_id#296159, canonical_id#296160, is_primary#296161, threshold#296162, create_date#296163], 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... [4040] [Cached]<br>count at <unknown>:0"];
}
}
4011->4012;
4012->4013;
4013->4014;
4014->4035;
4035->4036;
4036->4037;
4037->4038;
4038->4039;
4039->4040;
}
4014
4040