digraph G {
subgraph clusterstage_36434 {
label="Stage 36434";
158058 [labelType="html" label="JDBCRDD [158058]<br>cache at <unknown>:0"];
subgraph cluster381137 {
label="WholeStageCodegen (1)";
158059 [labelType="html" label="MapPartitionsRDD [158059]<br>count at <unknown>:0"];
}
subgraph cluster381139 {
label="mapPartitionsInternal";
158060 [labelType="html" label="MapPartitionsRDD [158060]<br>count at <unknown>:0"];
}
subgraph cluster381140 {
label="mapPartitionsInternal";
158061 [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#14922118,supplier_id#14922119,entity_name#14922120,city#14922121,state#14922122,country#14922123,supplier_type#14922124,declaring_supplier_id#14922125,canonical_id#14922126,is_primary#14922127,threshold#14922128,create_date#14922129] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [158061] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster381197 {
label="InMemoryTableScan";
158082 [labelType="html" label="MapPartitionsRDD [158082]<br>count at <unknown>:0"];
158083 [labelType="html" label="MapPartitionsRDD [158083]<br>count at <unknown>:0"];
158084 [labelType="html" label="MapPartitionsRDD [158084]<br>count at <unknown>:0"];
}
subgraph cluster381193 {
label="WholeStageCodegen (1)";
158085 [labelType="html" label="MapPartitionsRDD [158085]<br>count at <unknown>:0"];
}
subgraph cluster381198 {
label="mapPartitionsInternal";
158086 [labelType="html" label="MapPartitionsRDD [158086]<br>count at <unknown>:0"];
}
subgraph cluster381199 {
label="mapPartitionsInternal";
158087 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#14922126)\n +- InMemoryTableScan [brand_context_id#14922118, supplier_id#14922119, canonical_id#14922126, is_primary#14922127, entity_name#14922120, city#14922121, state#14922122, country#14922123, threshold#14922128, create_date#14922129], [isnotnull(canonical_id#14922126)]\n +- InMemoryRelation [brand_context_id#14922118, supplier_id#14922119, entity_name#14922120, city#14922121, state#14922122, country#14922123, supplier_type#14922124, declaring_supplier_id#14922125, canonical_id#14922126, is_primary#14922127, threshold#14922128, create_date#14922129], 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 ... [158087] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster381205 {
label="InMemoryTableScan";
158088 [labelType="html" label="MapPartitionsRDD [158088]<br>count at <unknown>:0"];
158089 [labelType="html" label="MapPartitionsRDD [158089]<br>count at <unknown>:0"];
158090 [labelType="html" label="MapPartitionsRDD [158090]<br>count at <unknown>:0"];
}
subgraph cluster381201 {
label="WholeStageCodegen (1)";
158091 [labelType="html" label="MapPartitionsRDD [158091]<br>count at <unknown>:0"];
}
subgraph cluster381200 {
label="Exchange";
158092 [labelType="html" label="MapPartitionsRDD [158092]<br>count at <unknown>:0"];
}
}
158058->158059;
158059->158060;
158060->158061;
158061->158082;
158082->158083;
158083->158084;
158084->158085;
158085->158086;
158086->158087;
158087->158088;
158088->158089;
158089->158090;
158090->158091;
158091->158092;
}
158061
158087