digraph G {
subgraph clusterstage_36213 {
label="Stage 36213";
157298 [labelType="html" label="JDBCRDD [157298]<br>cache at <unknown>:0"];
subgraph cluster379317 {
label="WholeStageCodegen (1)";
157299 [labelType="html" label="MapPartitionsRDD [157299]<br>count at <unknown>:0"];
}
subgraph cluster379319 {
label="mapPartitionsInternal";
157300 [labelType="html" label="MapPartitionsRDD [157300]<br>count at <unknown>:0"];
}
subgraph cluster379320 {
label="mapPartitionsInternal";
157301 [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#14892498,supplier_id#14892499,entity_name#14892500,city#14892501,state#14892502,country#14892503,supplier_type#14892504,declaring_supplier_id#14892505,canonical_id#14892506,is_primary#14892507,threshold#14892508,create_date#14892509] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [157301] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster379377 {
label="InMemoryTableScan";
157322 [labelType="html" label="MapPartitionsRDD [157322]<br>count at <unknown>:0"];
157323 [labelType="html" label="MapPartitionsRDD [157323]<br>count at <unknown>:0"];
157324 [labelType="html" label="MapPartitionsRDD [157324]<br>count at <unknown>:0"];
}
subgraph cluster379373 {
label="WholeStageCodegen (1)";
157325 [labelType="html" label="MapPartitionsRDD [157325]<br>count at <unknown>:0"];
}
subgraph cluster379378 {
label="mapPartitionsInternal";
157326 [labelType="html" label="MapPartitionsRDD [157326]<br>count at <unknown>:0"];
}
subgraph cluster379379 {
label="mapPartitionsInternal";
157327 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#14892506)\n +- InMemoryTableScan [brand_context_id#14892498, supplier_id#14892499, canonical_id#14892506, is_primary#14892507, entity_name#14892500, city#14892501, state#14892502, country#14892503, threshold#14892508, create_date#14892509], [isnotnull(canonical_id#14892506)]\n +- InMemoryRelation [brand_context_id#14892498, supplier_id#14892499, entity_name#14892500, city#14892501, state#14892502, country#14892503, supplier_type#14892504, declaring_supplier_id#14892505, canonical_id#14892506, is_primary#14892507, threshold#14892508, create_date#14892509], 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 ... [157327] [Cached]<br>count at <unknown>:0"];
}
}
157298->157299;
157299->157300;
157300->157301;
157301->157322;
157322->157323;
157323->157324;
157324->157325;
157325->157326;
157326->157327;
}
157301
157327