digraph G {
subgraph clusterstage_44298 {
label="Stage 44298";
192079 [labelType="html" label="JDBCRDD [192079]<br>cache at <unknown>:0"];
subgraph cluster452958 {
label="WholeStageCodegen (1)";
192080 [labelType="html" label="MapPartitionsRDD [192080]<br>count at <unknown>:0"];
}
subgraph cluster452960 {
label="mapPartitionsInternal";
192081 [labelType="html" label="MapPartitionsRDD [192081]<br>count at <unknown>:0"];
}
subgraph cluster452961 {
label="mapPartitionsInternal";
192082 [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#17328517,supplier_id#17328518,entity_name#17328519,city#17328520,state#17328521,country#17328522,supplier_type#17328523,declaring_supplier_id#17328524,canonical_id#17328525,is_primary#17328526,threshold#17328527,create_date#17328528] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [192082] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster453018 {
label="InMemoryTableScan";
192103 [labelType="html" label="MapPartitionsRDD [192103]<br>count at <unknown>:0"];
192104 [labelType="html" label="MapPartitionsRDD [192104]<br>count at <unknown>:0"];
192105 [labelType="html" label="MapPartitionsRDD [192105]<br>count at <unknown>:0"];
}
subgraph cluster453014 {
label="WholeStageCodegen (1)";
192106 [labelType="html" label="MapPartitionsRDD [192106]<br>count at <unknown>:0"];
}
subgraph cluster453019 {
label="mapPartitionsInternal";
192107 [labelType="html" label="MapPartitionsRDD [192107]<br>count at <unknown>:0"];
}
subgraph cluster453020 {
label="mapPartitionsInternal";
192108 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#17328525)\n +- InMemoryTableScan [brand_context_id#17328517, supplier_id#17328518, canonical_id#17328525, is_primary#17328526, entity_name#17328519, city#17328520, state#17328521, country#17328522, threshold#17328527, create_date#17328528], [isnotnull(canonical_id#17328525)]\n +- InMemoryRelation [brand_context_id#17328517, supplier_id#17328518, entity_name#17328519, city#17328520, state#17328521, country#17328522, supplier_type#17328523, declaring_supplier_id#17328524, canonical_id#17328525, is_primary#17328526, threshold#17328527, create_date#17328528], 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 ... [192108] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster453026 {
label="InMemoryTableScan";
192109 [labelType="html" label="MapPartitionsRDD [192109]<br>count at <unknown>:0"];
192110 [labelType="html" label="MapPartitionsRDD [192110]<br>count at <unknown>:0"];
192111 [labelType="html" label="MapPartitionsRDD [192111]<br>count at <unknown>:0"];
}
subgraph cluster453022 {
label="WholeStageCodegen (1)";
192112 [labelType="html" label="MapPartitionsRDD [192112]<br>count at <unknown>:0"];
}
subgraph cluster453021 {
label="Exchange";
192113 [labelType="html" label="MapPartitionsRDD [192113]<br>count at <unknown>:0"];
}
}
192079->192080;
192080->192081;
192081->192082;
192082->192103;
192103->192104;
192104->192105;
192105->192106;
192106->192107;
192107->192108;
192108->192109;
192109->192110;
192110->192111;
192111->192112;
192112->192113;
}
192082
192108