digraph G {
subgraph clusterstage_34147 {
label="Stage 34147";
150150 [labelType="html" label="JDBCRDD [150150]<br>cache at <unknown>:0"];
subgraph cluster362806 {
label="WholeStageCodegen (1)";
150151 [labelType="html" label="MapPartitionsRDD [150151]<br>count at <unknown>:0"];
}
subgraph cluster362808 {
label="mapPartitionsInternal";
150152 [labelType="html" label="MapPartitionsRDD [150152]<br>count at <unknown>:0"];
}
subgraph cluster362809 {
label="mapPartitionsInternal";
150153 [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#14334257,supplier_id#14334258,entity_name#14334259,city#14334260,state#14334261,country#14334262,supplier_type#14334263,declaring_supplier_id#14334264,canonical_id#14334265,is_primary#14334266,threshold#14334267,create_date#14334268] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [150153] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster362866 {
label="InMemoryTableScan";
150174 [labelType="html" label="MapPartitionsRDD [150174]<br>count at <unknown>:0"];
150175 [labelType="html" label="MapPartitionsRDD [150175]<br>count at <unknown>:0"];
150176 [labelType="html" label="MapPartitionsRDD [150176]<br>count at <unknown>:0"];
}
subgraph cluster362862 {
label="WholeStageCodegen (1)";
150177 [labelType="html" label="MapPartitionsRDD [150177]<br>count at <unknown>:0"];
}
subgraph cluster362867 {
label="mapPartitionsInternal";
150178 [labelType="html" label="MapPartitionsRDD [150178]<br>count at <unknown>:0"];
}
subgraph cluster362868 {
label="mapPartitionsInternal";
150179 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#14334265)\n +- InMemoryTableScan [brand_context_id#14334257, supplier_id#14334258, canonical_id#14334265, is_primary#14334266, entity_name#14334259, city#14334260, state#14334261, country#14334262, threshold#14334267, create_date#14334268], [isnotnull(canonical_id#14334265)]\n +- InMemoryRelation [brand_context_id#14334257, supplier_id#14334258, entity_name#14334259, city#14334260, state#14334261, country#14334262, supplier_type#14334263, declaring_supplier_id#14334264, canonical_id#14334265, is_primary#14334266, threshold#14334267, create_date#14334268], 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 ... [150179] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster362874 {
label="InMemoryTableScan";
150180 [labelType="html" label="MapPartitionsRDD [150180]<br>count at <unknown>:0"];
150181 [labelType="html" label="MapPartitionsRDD [150181]<br>count at <unknown>:0"];
150182 [labelType="html" label="MapPartitionsRDD [150182]<br>count at <unknown>:0"];
}
subgraph cluster362870 {
label="WholeStageCodegen (1)";
150183 [labelType="html" label="MapPartitionsRDD [150183]<br>count at <unknown>:0"];
}
subgraph cluster362869 {
label="Exchange";
150184 [labelType="html" label="MapPartitionsRDD [150184]<br>count at <unknown>:0"];
}
}
150150->150151;
150151->150152;
150152->150153;
150153->150174;
150174->150175;
150175->150176;
150176->150177;
150177->150178;
150178->150179;
150179->150180;
150180->150181;
150181->150182;
150182->150183;
150183->150184;
}
150153
150179