digraph G {
subgraph clusterstage_34977 {
label="Stage 34977";
153021 [labelType="html" label="JDBCRDD [153021]<br>cache at <unknown>:0"];
subgraph cluster369378 {
label="WholeStageCodegen (1)";
153022 [labelType="html" label="MapPartitionsRDD [153022]<br>count at <unknown>:0"];
}
subgraph cluster369380 {
label="mapPartitionsInternal";
153023 [labelType="html" label="MapPartitionsRDD [153023]<br>count at <unknown>:0"];
}
subgraph cluster369381 {
label="mapPartitionsInternal";
153024 [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#14585979,supplier_id#14585980,entity_name#14585981,city#14585982,state#14585983,country#14585984,supplier_type#14585985,declaring_supplier_id#14585986,canonical_id#14585987,is_primary#14585988,threshold#14585989,create_date#14585990] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [153024] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster369438 {
label="InMemoryTableScan";
153045 [labelType="html" label="MapPartitionsRDD [153045]<br>count at <unknown>:0"];
153046 [labelType="html" label="MapPartitionsRDD [153046]<br>count at <unknown>:0"];
153047 [labelType="html" label="MapPartitionsRDD [153047]<br>count at <unknown>:0"];
}
subgraph cluster369434 {
label="WholeStageCodegen (1)";
153048 [labelType="html" label="MapPartitionsRDD [153048]<br>count at <unknown>:0"];
}
subgraph cluster369439 {
label="mapPartitionsInternal";
153049 [labelType="html" label="MapPartitionsRDD [153049]<br>count at <unknown>:0"];
}
subgraph cluster369440 {
label="mapPartitionsInternal";
153050 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#14585987)\n +- InMemoryTableScan [brand_context_id#14585979, supplier_id#14585980, canonical_id#14585987, is_primary#14585988, entity_name#14585981, city#14585982, state#14585983, country#14585984, threshold#14585989, create_date#14585990], [isnotnull(canonical_id#14585987)]\n +- InMemoryRelation [brand_context_id#14585979, supplier_id#14585980, entity_name#14585981, city#14585982, state#14585983, country#14585984, supplier_type#14585985, declaring_supplier_id#14585986, canonical_id#14585987, is_primary#14585988, threshold#14585989, create_date#14585990], 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 ... [153050] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster369446 {
label="InMemoryTableScan";
153051 [labelType="html" label="MapPartitionsRDD [153051]<br>count at <unknown>:0"];
153052 [labelType="html" label="MapPartitionsRDD [153052]<br>count at <unknown>:0"];
153053 [labelType="html" label="MapPartitionsRDD [153053]<br>count at <unknown>:0"];
}
subgraph cluster369442 {
label="WholeStageCodegen (1)";
153054 [labelType="html" label="MapPartitionsRDD [153054]<br>count at <unknown>:0"];
}
subgraph cluster369441 {
label="Exchange";
153055 [labelType="html" label="MapPartitionsRDD [153055]<br>count at <unknown>:0"];
}
}
153021->153022;
153022->153023;
153023->153024;
153024->153045;
153045->153046;
153046->153047;
153047->153048;
153048->153049;
153049->153050;
153050->153051;
153051->153052;
153052->153053;
153053->153054;
153054->153055;
}
153024
153050