digraph G {
subgraph clusterstage_1146 {
label="Stage 1146";
3935 [labelType="html" label="JDBCRDD [3935]<br>cache at <unknown>:0"];
subgraph cluster9120 {
label="WholeStageCodegen (1)";
3936 [labelType="html" label="MapPartitionsRDD [3936]<br>count at <unknown>:0"];
}
subgraph cluster9122 {
label="mapPartitionsInternal";
3937 [labelType="html" label="MapPartitionsRDD [3937]<br>count at <unknown>:0"];
}
subgraph cluster9123 {
label="mapPartitionsInternal";
3938 [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#293190,supplier_id#293191,entity_name#293192,city#293193,state#293194,country#293195,supplier_type#293196,declaring_supplier_id#293197,canonical_id#293198,is_primary#293199,threshold#293200,create_date#293201] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [3938] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster9180 {
label="InMemoryTableScan";
3959 [labelType="html" label="MapPartitionsRDD [3959]<br>count at <unknown>:0"];
3960 [labelType="html" label="MapPartitionsRDD [3960]<br>count at <unknown>:0"];
3961 [labelType="html" label="MapPartitionsRDD [3961]<br>count at <unknown>:0"];
}
subgraph cluster9176 {
label="WholeStageCodegen (1)";
3962 [labelType="html" label="MapPartitionsRDD [3962]<br>count at <unknown>:0"];
}
subgraph cluster9181 {
label="mapPartitionsInternal";
3963 [labelType="html" label="MapPartitionsRDD [3963]<br>count at <unknown>:0"];
}
subgraph cluster9182 {
label="mapPartitionsInternal";
3964 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#293198)\n +- InMemoryTableScan [brand_context_id#293190, supplier_id#293191, canonical_id#293198, is_primary#293199, entity_name#293192, city#293193, state#293194, country#293195, threshold#293200, create_date#293201], [isnotnull(canonical_id#293198)]\n +- InMemoryRelation [brand_context_id#293190, supplier_id#293191, entity_name#293192, city#293193, state#293194, country#293195, supplier_type#293196, declaring_supplier_id#293197, canonical_id#293198, is_primary#293199, threshold#293200, create_date#293201], 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 v.canonical_id,\n v.is_prima... [3964] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster9188 {
label="InMemoryTableScan";
3965 [labelType="html" label="MapPartitionsRDD [3965]<br>count at <unknown>:0"];
3966 [labelType="html" label="MapPartitionsRDD [3966]<br>count at <unknown>:0"];
3967 [labelType="html" label="MapPartitionsRDD [3967]<br>count at <unknown>:0"];
}
subgraph cluster9184 {
label="WholeStageCodegen (1)";
3968 [labelType="html" label="MapPartitionsRDD [3968]<br>count at <unknown>:0"];
}
subgraph cluster9183 {
label="Exchange";
3969 [labelType="html" label="MapPartitionsRDD [3969]<br>count at <unknown>:0"];
}
}
3935->3936;
3936->3937;
3937->3938;
3938->3959;
3959->3960;
3960->3961;
3961->3962;
3962->3963;
3963->3964;
3964->3965;
3965->3966;
3966->3967;
3967->3968;
3968->3969;
}
3938
3964