digraph G {
subgraph clusterstage_878 {
label="Stage 878";
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 cluster6971 {
label="InMemoryTableScan";
3035 [labelType="html" label="MapPartitionsRDD [3035]<br>count at <unknown>:0"];
3036 [labelType="html" label="MapPartitionsRDD [3036]<br>count at <unknown>:0"];
3037 [labelType="html" label="MapPartitionsRDD [3037]<br>count at <unknown>:0"];
}
subgraph cluster6966 {
label="WholeStageCodegen (1)";
3038 [labelType="html" label="MapPartitionsRDD [3038]<br>count at <unknown>:0"];
}
subgraph cluster6972 {
label="mapPartitionsInternal";
3039 [labelType="html" label="MapPartitionsRDD [3039]<br>count at <unknown>:0"];
}
subgraph cluster6973 {
label="mapPartitionsInternal";
3040 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#257646, supplier_id#257647, entity_name#257648, city#257649, state#257650, country#257651, supplier_type#257652, declaring_supplier_id#257653, threshold#257656, create_date#257657]\n +- Filter isnull(canonical_id#257654)\n +- InMemoryTableScan [brand_context_id#257646, canonical_id#257654, city#257649, country#257651, create_date#257657, declaring_supplier_id#257653, entity_name#257648, state#257650, supplier_id#257647, supplier_type#257652, threshold#257656], [isnull(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.sup... [3040] [Cached]<br>count at <unknown>:0"];
}
}
3023->3024;
3024->3025;
3025->3026;
3026->3035;
3035->3036;
3036->3037;
3037->3038;
3038->3039;
3039->3040;
}
3026
3040