digraph G {
subgraph clusterstage_1164 {
label="Stage 1164";
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 cluster9337 {
label="InMemoryTableScan";
4023 [labelType="html" label="MapPartitionsRDD [4023]<br>count at <unknown>:0"];
4024 [labelType="html" label="MapPartitionsRDD [4024]<br>count at <unknown>:0"];
4025 [labelType="html" label="MapPartitionsRDD [4025]<br>count at <unknown>:0"];
}
subgraph cluster9332 {
label="WholeStageCodegen (1)";
4026 [labelType="html" label="MapPartitionsRDD [4026]<br>count at <unknown>:0"];
}
subgraph cluster9338 {
label="mapPartitionsInternal";
4027 [labelType="html" label="MapPartitionsRDD [4027]<br>count at <unknown>:0"];
}
subgraph cluster9339 {
label="mapPartitionsInternal";
4028 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#296152, supplier_id#296153, entity_name#296154, city#296155, state#296156, country#296157, supplier_type#296158, declaring_supplier_id#296159, threshold#296162, create_date#296163]\n +- Filter isnull(canonical_id#296160)\n +- InMemoryTableScan [brand_context_id#296152, canonical_id#296160, city#296155, country#296157, create_date#296163, declaring_supplier_id#296159, entity_name#296154, state#296156, supplier_id#296153, supplier_type#296158, threshold#296162], [isnull(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.sup... [4028] [Cached]<br>count at <unknown>:0"];
}
}
4011->4012;
4012->4013;
4013->4014;
4014->4023;
4023->4024;
4024->4025;
4025->4026;
4026->4027;
4027->4028;
}
4014
4028