digraph G {
subgraph clusterstage_36390 {
label="Stage 36390";
157906 [labelType="html" label="JDBCRDD [157906]<br>cache at <unknown>:0"];
subgraph cluster380773 {
label="WholeStageCodegen (1)";
157907 [labelType="html" label="MapPartitionsRDD [157907]<br>count at <unknown>:0"];
}
subgraph cluster380775 {
label="mapPartitionsInternal";
157908 [labelType="html" label="MapPartitionsRDD [157908]<br>count at <unknown>:0"];
}
subgraph cluster380776 {
label="mapPartitionsInternal";
157909 [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#14916194,supplier_id#14916195,entity_name#14916196,city#14916197,state#14916198,country#14916199,supplier_type#14916200,declaring_supplier_id#14916201,canonical_id#14916202,is_primary#14916203,threshold#14916204,create_date#14916205] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [157909] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster380833 {
label="InMemoryTableScan";
157930 [labelType="html" label="MapPartitionsRDD [157930]<br>count at <unknown>:0"];
157931 [labelType="html" label="MapPartitionsRDD [157931]<br>count at <unknown>:0"];
157932 [labelType="html" label="MapPartitionsRDD [157932]<br>count at <unknown>:0"];
}
subgraph cluster380829 {
label="WholeStageCodegen (1)";
157933 [labelType="html" label="MapPartitionsRDD [157933]<br>count at <unknown>:0"];
}
subgraph cluster380834 {
label="mapPartitionsInternal";
157934 [labelType="html" label="MapPartitionsRDD [157934]<br>count at <unknown>:0"];
}
subgraph cluster380835 {
label="mapPartitionsInternal";
157935 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#14916202)\n +- InMemoryTableScan [brand_context_id#14916194, supplier_id#14916195, canonical_id#14916202, is_primary#14916203, entity_name#14916196, city#14916197, state#14916198, country#14916199, threshold#14916204, create_date#14916205], [isnotnull(canonical_id#14916202)]\n +- InMemoryRelation [brand_context_id#14916194, supplier_id#14916195, entity_name#14916196, city#14916197, state#14916198, country#14916199, supplier_type#14916200, declaring_supplier_id#14916201, canonical_id#14916202, is_primary#14916203, threshold#14916204, create_date#14916205], 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 ... [157935] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster380841 {
label="InMemoryTableScan";
157936 [labelType="html" label="MapPartitionsRDD [157936]<br>count at <unknown>:0"];
157937 [labelType="html" label="MapPartitionsRDD [157937]<br>count at <unknown>:0"];
157938 [labelType="html" label="MapPartitionsRDD [157938]<br>count at <unknown>:0"];
}
subgraph cluster380837 {
label="WholeStageCodegen (1)";
157939 [labelType="html" label="MapPartitionsRDD [157939]<br>count at <unknown>:0"];
}
subgraph cluster380836 {
label="Exchange";
157940 [labelType="html" label="MapPartitionsRDD [157940]<br>count at <unknown>:0"];
}
}
157906->157907;
157907->157908;
157908->157909;
157909->157930;
157930->157931;
157931->157932;
157932->157933;
157933->157934;
157934->157935;
157935->157936;
157936->157937;
157937->157938;
157938->157939;
157939->157940;
}
157909
157935