digraph G {
subgraph clusterstage_36279 {
label="Stage 36279";
157526 [labelType="html" label="JDBCRDD [157526]<br>cache at <unknown>:0"];
subgraph cluster379863 {
label="WholeStageCodegen (1)";
157527 [labelType="html" label="MapPartitionsRDD [157527]<br>count at <unknown>:0"];
}
subgraph cluster379865 {
label="mapPartitionsInternal";
157528 [labelType="html" label="MapPartitionsRDD [157528]<br>count at <unknown>:0"];
}
subgraph cluster379866 {
label="mapPartitionsInternal";
157529 [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#14901384,supplier_id#14901385,entity_name#14901386,city#14901387,state#14901388,country#14901389,supplier_type#14901390,declaring_supplier_id#14901391,canonical_id#14901392,is_primary#14901393,threshold#14901394,create_date#14901395] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [157529] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster379923 {
label="InMemoryTableScan";
157550 [labelType="html" label="MapPartitionsRDD [157550]<br>count at <unknown>:0"];
157551 [labelType="html" label="MapPartitionsRDD [157551]<br>count at <unknown>:0"];
157552 [labelType="html" label="MapPartitionsRDD [157552]<br>count at <unknown>:0"];
}
subgraph cluster379919 {
label="WholeStageCodegen (1)";
157553 [labelType="html" label="MapPartitionsRDD [157553]<br>count at <unknown>:0"];
}
subgraph cluster379924 {
label="mapPartitionsInternal";
157554 [labelType="html" label="MapPartitionsRDD [157554]<br>count at <unknown>:0"];
}
subgraph cluster379925 {
label="mapPartitionsInternal";
157555 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#14901392)\n +- InMemoryTableScan [brand_context_id#14901384, supplier_id#14901385, canonical_id#14901392, is_primary#14901393, entity_name#14901386, city#14901387, state#14901388, country#14901389, threshold#14901394, create_date#14901395], [isnotnull(canonical_id#14901392)]\n +- InMemoryRelation [brand_context_id#14901384, supplier_id#14901385, entity_name#14901386, city#14901387, state#14901388, country#14901389, supplier_type#14901390, declaring_supplier_id#14901391, canonical_id#14901392, is_primary#14901393, threshold#14901394, create_date#14901395], 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 ... [157555] [Cached]<br>count at <unknown>:0"];
}
}
157526->157527;
157527->157528;
157528->157529;
157529->157550;
157550->157551;
157551->157552;
157552->157553;
157553->157554;
157554->157555;
}
157529
157555