digraph G {
subgraph clusterstage_27700 {
label="Stage 27700";
121129 [labelType="html" label="JDBCRDD [121129]<br>cache at <unknown>:0"];
subgraph cluster302936 {
label="WholeStageCodegen (1)";
121130 [labelType="html" label="MapPartitionsRDD [121130]<br>count at <unknown>:0"];
}
subgraph cluster302938 {
label="mapPartitionsInternal";
121131 [labelType="html" label="MapPartitionsRDD [121131]<br>count at <unknown>:0"];
}
subgraph cluster302939 {
label="mapPartitionsInternal";
121132 [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#12301221,supplier_id#12301222,entity_name#12301223,city#12301224,state#12301225,country#12301226,supplier_type#12301227,declaring_supplier_id#12301228,canonical_id#12301229,is_primary#12301230,threshold#12301231,create_date#12301232] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [121132] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster302971 {
label="InMemoryTableScan";
121141 [labelType="html" label="MapPartitionsRDD [121141]<br>count at <unknown>:0"];
121142 [labelType="html" label="MapPartitionsRDD [121142]<br>count at <unknown>:0"];
121143 [labelType="html" label="MapPartitionsRDD [121143]<br>count at <unknown>:0"];
}
subgraph cluster302966 {
label="WholeStageCodegen (1)";
121144 [labelType="html" label="MapPartitionsRDD [121144]<br>count at <unknown>:0"];
}
subgraph cluster302972 {
label="mapPartitionsInternal";
121145 [labelType="html" label="MapPartitionsRDD [121145]<br>count at <unknown>:0"];
}
subgraph cluster302973 {
label="mapPartitionsInternal";
121146 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#12301221, supplier_id#12301222, entity_name#12301223, city#12301224, state#12301225, country#12301226, supplier_type#12301227, declaring_supplier_id#12301228, threshold#12301231, create_date#12301232]\n +- Filter isnull(canonical_id#12301229)\n +- InMemoryTableScan [brand_context_id#12301221, canonical_id#12301229, city#12301224, country#12301226, create_date#12301232, declaring_supplier_id#12301228, entity_name#12301223, state#12301225, supplier_id#12301222, supplier_type#12301227, threshold#12301231], [isnull(canonical_id#12301229)]\n +- InMemoryRelation [brand_context_id#12301221, supplier_id#12301222, entity_name#12301223, city#12301224, state#12301225, country#12301226, supplier_type#12301227, declaring_supplier_id#12301228, canonical_id#12301229, is_primary#12301230, threshold#12301231, create_date#12301232], StorageLevel(disk, memory, deserialized, 1 replicas)\n +- *(1) Scan JDBCRelation((\n SEL... [121146] [Cached]<br>count at <unknown>:0"];
}
}
121129->121130;
121130->121131;
121131->121132;
121132->121141;
121141->121142;
121142->121143;
121143->121144;
121144->121145;
121145->121146;
}
121132
121146