digraph G {
subgraph clusterstage_44287 {
label="Stage 44287";
192041 [labelType="html" label="JDBCRDD [192041]<br>cache at <unknown>:0"];
subgraph cluster452867 {
label="WholeStageCodegen (1)";
192042 [labelType="html" label="MapPartitionsRDD [192042]<br>count at <unknown>:0"];
}
subgraph cluster452869 {
label="mapPartitionsInternal";
192043 [labelType="html" label="MapPartitionsRDD [192043]<br>count at <unknown>:0"];
}
subgraph cluster452870 {
label="mapPartitionsInternal";
192044 [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#17327036,supplier_id#17327037,entity_name#17327038,city#17327039,state#17327040,country#17327041,supplier_type#17327042,declaring_supplier_id#17327043,canonical_id#17327044,is_primary#17327045,threshold#17327046,create_date#17327047] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [192044] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster452927 {
label="InMemoryTableScan";
192065 [labelType="html" label="MapPartitionsRDD [192065]<br>count at <unknown>:0"];
192066 [labelType="html" label="MapPartitionsRDD [192066]<br>count at <unknown>:0"];
192067 [labelType="html" label="MapPartitionsRDD [192067]<br>count at <unknown>:0"];
}
subgraph cluster452923 {
label="WholeStageCodegen (1)";
192068 [labelType="html" label="MapPartitionsRDD [192068]<br>count at <unknown>:0"];
}
subgraph cluster452928 {
label="mapPartitionsInternal";
192069 [labelType="html" label="MapPartitionsRDD [192069]<br>count at <unknown>:0"];
}
subgraph cluster452929 {
label="mapPartitionsInternal";
192070 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#17327044)\n +- InMemoryTableScan [brand_context_id#17327036, supplier_id#17327037, canonical_id#17327044, is_primary#17327045, entity_name#17327038, city#17327039, state#17327040, country#17327041, threshold#17327046, create_date#17327047], [isnotnull(canonical_id#17327044)]\n +- InMemoryRelation [brand_context_id#17327036, supplier_id#17327037, entity_name#17327038, city#17327039, state#17327040, country#17327041, supplier_type#17327042, declaring_supplier_id#17327043, canonical_id#17327044, is_primary#17327045, threshold#17327046, create_date#17327047], 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 ... [192070] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster452935 {
label="InMemoryTableScan";
192071 [labelType="html" label="MapPartitionsRDD [192071]<br>count at <unknown>:0"];
192072 [labelType="html" label="MapPartitionsRDD [192072]<br>count at <unknown>:0"];
192073 [labelType="html" label="MapPartitionsRDD [192073]<br>count at <unknown>:0"];
}
subgraph cluster452931 {
label="WholeStageCodegen (1)";
192074 [labelType="html" label="MapPartitionsRDD [192074]<br>count at <unknown>:0"];
}
subgraph cluster452930 {
label="Exchange";
192075 [labelType="html" label="MapPartitionsRDD [192075]<br>count at <unknown>:0"];
}
}
192041->192042;
192042->192043;
192043->192044;
192044->192065;
192065->192066;
192066->192067;
192067->192068;
192068->192069;
192069->192070;
192070->192071;
192071->192072;
192072->192073;
192073->192074;
192074->192075;
}
192044
192070