digraph G {
subgraph clusterstage_27722 {
label="Stage 27722";
121205 [labelType="html" label="JDBCRDD [121205]<br>cache at <unknown>:0"];
subgraph cluster303118 {
label="WholeStageCodegen (1)";
121206 [labelType="html" label="MapPartitionsRDD [121206]<br>count at <unknown>:0"];
}
subgraph cluster303120 {
label="mapPartitionsInternal";
121207 [labelType="html" label="MapPartitionsRDD [121207]<br>count at <unknown>:0"];
}
subgraph cluster303121 {
label="mapPartitionsInternal";
121208 [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#12304183,supplier_id#12304184,entity_name#12304185,city#12304186,state#12304187,country#12304188,supplier_type#12304189,declaring_supplier_id#12304190,canonical_id#12304191,is_primary#12304192,threshold#12304193,create_date#12304194] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [121208] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster303153 {
label="InMemoryTableScan";
121217 [labelType="html" label="MapPartitionsRDD [121217]<br>count at <unknown>:0"];
121218 [labelType="html" label="MapPartitionsRDD [121218]<br>count at <unknown>:0"];
121219 [labelType="html" label="MapPartitionsRDD [121219]<br>count at <unknown>:0"];
}
subgraph cluster303148 {
label="WholeStageCodegen (1)";
121220 [labelType="html" label="MapPartitionsRDD [121220]<br>count at <unknown>:0"];
}
subgraph cluster303154 {
label="mapPartitionsInternal";
121221 [labelType="html" label="MapPartitionsRDD [121221]<br>count at <unknown>:0"];
}
subgraph cluster303155 {
label="mapPartitionsInternal";
121222 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#12304183, supplier_id#12304184, entity_name#12304185, city#12304186, state#12304187, country#12304188, supplier_type#12304189, declaring_supplier_id#12304190, threshold#12304193, create_date#12304194]\n +- Filter isnull(canonical_id#12304191)\n +- InMemoryTableScan [brand_context_id#12304183, canonical_id#12304191, city#12304186, country#12304188, create_date#12304194, declaring_supplier_id#12304190, entity_name#12304185, state#12304187, supplier_id#12304184, supplier_type#12304189, threshold#12304193], [isnull(canonical_id#12304191)]\n +- InMemoryRelation [brand_context_id#12304183, supplier_id#12304184, entity_name#12304185, city#12304186, state#12304187, country#12304188, supplier_type#12304189, declaring_supplier_id#12304190, canonical_id#12304191, is_primary#12304192, threshold#12304193, create_date#12304194], StorageLevel(disk, memory, deserialized, 1 replicas)\n +- *(1) Scan JDBCRelation((\n SEL... [121222] [Cached]<br>count at <unknown>:0"];
}
}
121205->121206;
121206->121207;
121207->121208;
121208->121217;
121217->121218;
121218->121219;
121219->121220;
121220->121221;
121221->121222;
}
121208
121222