digraph G {
subgraph clusterstage_1087 {
label="Stage 1087";
3745 [labelType="html" label="JDBCRDD [3745]<br>cache at <unknown>:0"];
subgraph cluster8665 {
label="WholeStageCodegen (1)";
3746 [labelType="html" label="MapPartitionsRDD [3746]<br>count at <unknown>:0"];
}
subgraph cluster8667 {
label="mapPartitionsInternal";
3747 [labelType="html" label="MapPartitionsRDD [3747]<br>count at <unknown>:0"];
}
subgraph cluster8668 {
label="mapPartitionsInternal";
3748 [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#285785,supplier_id#285786,entity_name#285787,city#285788,state#285789,country#285790,supplier_type#285791,declaring_supplier_id#285792,canonical_id#285793,is_primary#285794,threshold#285795,create_date#285796] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [3748] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster8700 {
label="InMemoryTableScan";
3757 [labelType="html" label="MapPartitionsRDD [3757]<br>count at <unknown>:0"];
3758 [labelType="html" label="MapPartitionsRDD [3758]<br>count at <unknown>:0"];
3759 [labelType="html" label="MapPartitionsRDD [3759]<br>count at <unknown>:0"];
}
subgraph cluster8695 {
label="WholeStageCodegen (1)";
3760 [labelType="html" label="MapPartitionsRDD [3760]<br>count at <unknown>:0"];
}
subgraph cluster8701 {
label="mapPartitionsInternal";
3761 [labelType="html" label="MapPartitionsRDD [3761]<br>count at <unknown>:0"];
}
subgraph cluster8702 {
label="mapPartitionsInternal";
3762 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#285785, supplier_id#285786, entity_name#285787, city#285788, state#285789, country#285790, supplier_type#285791, declaring_supplier_id#285792, threshold#285795, create_date#285796]\n +- Filter isnull(canonical_id#285793)\n +- InMemoryTableScan [brand_context_id#285785, canonical_id#285793, city#285788, country#285790, create_date#285796, declaring_supplier_id#285792, entity_name#285787, state#285789, supplier_id#285786, supplier_type#285791, threshold#285795], [isnull(canonical_id#285793)]\n +- InMemoryRelation [brand_context_id#285785, supplier_id#285786, entity_name#285787, city#285788, state#285789, country#285790, supplier_type#285791, declaring_supplier_id#285792, canonical_id#285793, is_primary#285794, threshold#285795, create_date#285796], StorageLevel(disk, memory, deserialized, 1 replicas)\n +- *(1) Scan JDBCRelation((\n SELECT DISTINCT\n v.brand_context_id,\n v.sup... [3762] [Cached]<br>count at <unknown>:0"];
}
}
3745->3746;
3746->3747;
3747->3748;
3748->3757;
3757->3758;
3758->3759;
3759->3760;
3760->3761;
3761->3762;
}
3748
3762