digraph G {
subgraph clusterstage_881 {
label="Stage 881";
3023 [labelType="html" label="JDBCRDD [3023]<br>cache at <unknown>:0"];
subgraph cluster6936 {
label="WholeStageCodegen (1)";
3024 [labelType="html" label="MapPartitionsRDD [3024]<br>count at <unknown>:0"];
}
subgraph cluster6938 {
label="mapPartitionsInternal";
3025 [labelType="html" label="MapPartitionsRDD [3025]<br>count at <unknown>:0"];
}
subgraph cluster6939 {
label="mapPartitionsInternal";
3026 [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#257646,supplier_id#257647,entity_name#257648,city#257649,state#257650,country#257651,supplier_type#257652,declaring_supplier_id#257653,canonical_id#257654,is_primary#257655,threshold#257656,create_date#257657] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [3026] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster6996 {
label="InMemoryTableScan";
3047 [labelType="html" label="MapPartitionsRDD [3047]<br>count at <unknown>:0"];
3048 [labelType="html" label="MapPartitionsRDD [3048]<br>count at <unknown>:0"];
3049 [labelType="html" label="MapPartitionsRDD [3049]<br>count at <unknown>:0"];
}
subgraph cluster6992 {
label="WholeStageCodegen (1)";
3050 [labelType="html" label="MapPartitionsRDD [3050]<br>count at <unknown>:0"];
}
subgraph cluster6997 {
label="mapPartitionsInternal";
3051 [labelType="html" label="MapPartitionsRDD [3051]<br>count at <unknown>:0"];
}
subgraph cluster6998 {
label="mapPartitionsInternal";
3052 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#257654)\n +- InMemoryTableScan [brand_context_id#257646, supplier_id#257647, canonical_id#257654, is_primary#257655, entity_name#257648, city#257649, state#257650, country#257651, threshold#257656, create_date#257657], [isnotnull(canonical_id#257654)]\n +- InMemoryRelation [brand_context_id#257646, supplier_id#257647, entity_name#257648, city#257649, state#257650, country#257651, supplier_type#257652, declaring_supplier_id#257653, canonical_id#257654, is_primary#257655, threshold#257656, create_date#257657], 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... [3052] [Cached]<br>count at <unknown>:0"];
}
}
3023->3024;
3024->3025;
3025->3026;
3026->3047;
3047->3048;
3048->3049;
3049->3050;
3050->3051;
3051->3052;
}
3026
3052