digraph G {
subgraph clusterstage_1109 {
label="Stage 1109";
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 cluster8882 {
label="InMemoryTableScan";
3833 [labelType="html" label="MapPartitionsRDD [3833]<br>count at <unknown>:0"];
3834 [labelType="html" label="MapPartitionsRDD [3834]<br>count at <unknown>:0"];
3835 [labelType="html" label="MapPartitionsRDD [3835]<br>count at <unknown>:0"];
}
subgraph cluster8877 {
label="WholeStageCodegen (1)";
3836 [labelType="html" label="MapPartitionsRDD [3836]<br>count at <unknown>:0"];
}
subgraph cluster8883 {
label="mapPartitionsInternal";
3837 [labelType="html" label="MapPartitionsRDD [3837]<br>count at <unknown>:0"];
}
subgraph cluster8884 {
label="mapPartitionsInternal";
3838 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#288747, supplier_id#288748, entity_name#288749, city#288750, state#288751, country#288752, supplier_type#288753, declaring_supplier_id#288754, threshold#288757, create_date#288758]\n +- Filter isnull(canonical_id#288755)\n +- InMemoryTableScan [brand_context_id#288747, canonical_id#288755, city#288750, country#288752, create_date#288758, declaring_supplier_id#288754, entity_name#288749, state#288751, supplier_id#288748, supplier_type#288753, threshold#288757], [isnull(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.sup... [3838] [Cached]<br>count at <unknown>:0"];
}
}
3821->3822;
3822->3823;
3823->3824;
3824->3833;
3833->3834;
3834->3835;
3835->3836;
3836->3837;
3837->3838;
}
3824
3838