digraph G {
subgraph clusterstage_34245 {
label="Stage 34245";
150492 [labelType="html" label="JDBCRDD [150492]<br>cache at <unknown>:0"];
subgraph cluster363625 {
label="WholeStageCodegen (1)";
150493 [labelType="html" label="MapPartitionsRDD [150493]<br>count at <unknown>:0"];
}
subgraph cluster363627 {
label="mapPartitionsInternal";
150494 [labelType="html" label="MapPartitionsRDD [150494]<br>count at <unknown>:0"];
}
subgraph cluster363628 {
label="mapPartitionsInternal";
150495 [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#14347586,supplier_id#14347587,entity_name#14347588,city#14347589,state#14347590,country#14347591,supplier_type#14347592,declaring_supplier_id#14347593,canonical_id#14347594,is_primary#14347595,threshold#14347596,create_date#14347597] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [150495] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster363685 {
label="InMemoryTableScan";
150516 [labelType="html" label="MapPartitionsRDD [150516]<br>count at <unknown>:0"];
150517 [labelType="html" label="MapPartitionsRDD [150517]<br>count at <unknown>:0"];
150518 [labelType="html" label="MapPartitionsRDD [150518]<br>count at <unknown>:0"];
}
subgraph cluster363681 {
label="WholeStageCodegen (1)";
150519 [labelType="html" label="MapPartitionsRDD [150519]<br>count at <unknown>:0"];
}
subgraph cluster363686 {
label="mapPartitionsInternal";
150520 [labelType="html" label="MapPartitionsRDD [150520]<br>count at <unknown>:0"];
}
subgraph cluster363687 {
label="mapPartitionsInternal";
150521 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#14347594)\n +- InMemoryTableScan [brand_context_id#14347586, supplier_id#14347587, canonical_id#14347594, is_primary#14347595, entity_name#14347588, city#14347589, state#14347590, country#14347591, threshold#14347596, create_date#14347597], [isnotnull(canonical_id#14347594)]\n +- InMemoryRelation [brand_context_id#14347586, supplier_id#14347587, entity_name#14347588, city#14347589, state#14347590, country#14347591, supplier_type#14347592, declaring_supplier_id#14347593, canonical_id#14347594, is_primary#14347595, threshold#14347596, create_date#14347597], 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 ... [150521] [Cached]<br>count at <unknown>:0"];
}
}
150492->150493;
150493->150494;
150494->150495;
150495->150516;
150516->150517;
150517->150518;
150518->150519;
150519->150520;
150520->150521;
}
150495
150521