digraph G {
subgraph clusterstage_1113 {
label="Stage 1113";
3821 [labelType="html" label="JDBCRDD [3821]<br>cache at <unknown>:0"];
subgraph cluster8847 {
label="WholeStageCodegen (1)";
3822 [labelType="html" label="MapPartitionsRDD [3822]<br>count at <unknown>:0"];
}
subgraph cluster8849 {
label="mapPartitionsInternal";
3823 [labelType="html" label="MapPartitionsRDD [3823]<br>count at <unknown>:0"];
}
subgraph cluster8850 {
label="mapPartitionsInternal";
3824 [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#288747,supplier_id#288748,entity_name#288749,city#288750,state#288751,country#288752,supplier_type#288753,declaring_supplier_id#288754,canonical_id#288755,is_primary#288756,threshold#288757,create_date#288758] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [3824] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster8907 {
label="InMemoryTableScan";
3845 [labelType="html" label="MapPartitionsRDD [3845]<br>count at <unknown>:0"];
3846 [labelType="html" label="MapPartitionsRDD [3846]<br>count at <unknown>:0"];
3847 [labelType="html" label="MapPartitionsRDD [3847]<br>count at <unknown>:0"];
}
subgraph cluster8903 {
label="WholeStageCodegen (1)";
3848 [labelType="html" label="MapPartitionsRDD [3848]<br>count at <unknown>:0"];
}
subgraph cluster8908 {
label="mapPartitionsInternal";
3849 [labelType="html" label="MapPartitionsRDD [3849]<br>count at <unknown>:0"];
}
subgraph cluster8909 {
label="mapPartitionsInternal";
3850 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#288755)\n +- InMemoryTableScan [brand_context_id#288747, supplier_id#288748, canonical_id#288755, is_primary#288756, entity_name#288749, city#288750, state#288751, country#288752, threshold#288757, create_date#288758], [isnotnull(canonical_id#288755)]\n +- InMemoryRelation [brand_context_id#288747, supplier_id#288748, entity_name#288749, city#288750, state#288751, country#288752, supplier_type#288753, declaring_supplier_id#288754, canonical_id#288755, is_primary#288756, threshold#288757, create_date#288758], 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... [3850] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster8915 {
label="InMemoryTableScan";
3851 [labelType="html" label="MapPartitionsRDD [3851]<br>count at <unknown>:0"];
3852 [labelType="html" label="MapPartitionsRDD [3852]<br>count at <unknown>:0"];
3853 [labelType="html" label="MapPartitionsRDD [3853]<br>count at <unknown>:0"];
}
subgraph cluster8911 {
label="WholeStageCodegen (1)";
3854 [labelType="html" label="MapPartitionsRDD [3854]<br>count at <unknown>:0"];
}
subgraph cluster8910 {
label="Exchange";
3855 [labelType="html" label="MapPartitionsRDD [3855]<br>count at <unknown>:0"];
}
}
3821->3822;
3822->3823;
3823->3824;
3824->3845;
3845->3846;
3846->3847;
3847->3848;
3848->3849;
3849->3850;
3850->3851;
3851->3852;
3852->3853;
3853->3854;
3854->3855;
}
3824
3850