digraph G {
subgraph clusterstage_44320 {
label="Stage 44320";
192155 [labelType="html" label="JDBCRDD [192155]<br>cache at <unknown>:0"];
subgraph cluster453140 {
label="WholeStageCodegen (1)";
192156 [labelType="html" label="MapPartitionsRDD [192156]<br>count at <unknown>:0"];
}
subgraph cluster453142 {
label="mapPartitionsInternal";
192157 [labelType="html" label="MapPartitionsRDD [192157]<br>count at <unknown>:0"];
}
subgraph cluster453143 {
label="mapPartitionsInternal";
192158 [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#17331479,supplier_id#17331480,entity_name#17331481,city#17331482,state#17331483,country#17331484,supplier_type#17331485,declaring_supplier_id#17331486,canonical_id#17331487,is_primary#17331488,threshold#17331489,create_date#17331490] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [192158] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster453200 {
label="InMemoryTableScan";
192179 [labelType="html" label="MapPartitionsRDD [192179]<br>count at <unknown>:0"];
192180 [labelType="html" label="MapPartitionsRDD [192180]<br>count at <unknown>:0"];
192181 [labelType="html" label="MapPartitionsRDD [192181]<br>count at <unknown>:0"];
}
subgraph cluster453196 {
label="WholeStageCodegen (1)";
192182 [labelType="html" label="MapPartitionsRDD [192182]<br>count at <unknown>:0"];
}
subgraph cluster453201 {
label="mapPartitionsInternal";
192183 [labelType="html" label="MapPartitionsRDD [192183]<br>count at <unknown>:0"];
}
subgraph cluster453202 {
label="mapPartitionsInternal";
192184 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#17331487)\n +- InMemoryTableScan [brand_context_id#17331479, supplier_id#17331480, canonical_id#17331487, is_primary#17331488, entity_name#17331481, city#17331482, state#17331483, country#17331484, threshold#17331489, create_date#17331490], [isnotnull(canonical_id#17331487)]\n +- InMemoryRelation [brand_context_id#17331479, supplier_id#17331480, entity_name#17331481, city#17331482, state#17331483, country#17331484, supplier_type#17331485, declaring_supplier_id#17331486, canonical_id#17331487, is_primary#17331488, threshold#17331489, create_date#17331490], 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 ... [192184] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster453208 {
label="InMemoryTableScan";
192185 [labelType="html" label="MapPartitionsRDD [192185]<br>count at <unknown>:0"];
192186 [labelType="html" label="MapPartitionsRDD [192186]<br>count at <unknown>:0"];
192187 [labelType="html" label="MapPartitionsRDD [192187]<br>count at <unknown>:0"];
}
subgraph cluster453204 {
label="WholeStageCodegen (1)";
192188 [labelType="html" label="MapPartitionsRDD [192188]<br>count at <unknown>:0"];
}
subgraph cluster453203 {
label="Exchange";
192189 [labelType="html" label="MapPartitionsRDD [192189]<br>count at <unknown>:0"];
}
}
192155->192156;
192156->192157;
192157->192158;
192158->192179;
192179->192180;
192180->192181;
192181->192182;
192182->192183;
192183->192184;
192184->192185;
192185->192186;
192186->192187;
192187->192188;
192188->192189;
}
192158
192184