digraph G {
subgraph clusterstage_36641 {
label="Stage 36641";
158754 [labelType="html" label="JDBCRDD [158754]<br>cache at <unknown>:0"];
subgraph cluster382905 {
label="WholeStageCodegen (1)";
158755 [labelType="html" label="MapPartitionsRDD [158755]<br>count at <unknown>:0"];
}
subgraph cluster382907 {
label="mapPartitionsInternal";
158756 [labelType="html" label="MapPartitionsRDD [158756]<br>count at <unknown>:0"];
}
subgraph cluster382908 {
label="mapPartitionsInternal";
158757 [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#14947376,supplier_id#14947377,entity_name#14947378,city#14947379,state#14947380,country#14947381,supplier_type#14947382,declaring_supplier_id#14947383,canonical_id#14947384,is_primary#14947385,threshold#14947386,create_date#14947387] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [158757] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster382965 {
label="InMemoryTableScan";
158778 [labelType="html" label="MapPartitionsRDD [158778]<br>count at <unknown>:0"];
158779 [labelType="html" label="MapPartitionsRDD [158779]<br>count at <unknown>:0"];
158780 [labelType="html" label="MapPartitionsRDD [158780]<br>count at <unknown>:0"];
}
subgraph cluster382961 {
label="WholeStageCodegen (1)";
158781 [labelType="html" label="MapPartitionsRDD [158781]<br>count at <unknown>:0"];
}
subgraph cluster382966 {
label="mapPartitionsInternal";
158782 [labelType="html" label="MapPartitionsRDD [158782]<br>count at <unknown>:0"];
}
subgraph cluster382967 {
label="mapPartitionsInternal";
158783 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#14947384)\n +- InMemoryTableScan [brand_context_id#14947376, supplier_id#14947377, canonical_id#14947384, is_primary#14947385, entity_name#14947378, city#14947379, state#14947380, country#14947381, threshold#14947386, create_date#14947387], [isnotnull(canonical_id#14947384)]\n +- InMemoryRelation [brand_context_id#14947376, supplier_id#14947377, entity_name#14947378, city#14947379, state#14947380, country#14947381, supplier_type#14947382, declaring_supplier_id#14947383, canonical_id#14947384, is_primary#14947385, threshold#14947386, create_date#14947387], 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 ... [158783] [Cached]<br>count at <unknown>:0"];
}
}
158754->158755;
158755->158756;
158756->158757;
158757->158778;
158778->158779;
158779->158780;
158780->158781;
158781->158782;
158782->158783;
}
158757
158783