digraph G {
subgraph clusterstage_34165 {
label="Stage 34165";
150226 [labelType="html" label="JDBCRDD [150226]<br>cache at <unknown>:0"];
subgraph cluster362988 {
label="WholeStageCodegen (1)";
150227 [labelType="html" label="MapPartitionsRDD [150227]<br>count at <unknown>:0"];
}
subgraph cluster362990 {
label="mapPartitionsInternal";
150228 [labelType="html" label="MapPartitionsRDD [150228]<br>count at <unknown>:0"];
}
subgraph cluster362991 {
label="mapPartitionsInternal";
150229 [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#14337219,supplier_id#14337220,entity_name#14337221,city#14337222,state#14337223,country#14337224,supplier_type#14337225,declaring_supplier_id#14337226,canonical_id#14337227,is_primary#14337228,threshold#14337229,create_date#14337230] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [150229] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster363023 {
label="InMemoryTableScan";
150238 [labelType="html" label="MapPartitionsRDD [150238]<br>count at <unknown>:0"];
150239 [labelType="html" label="MapPartitionsRDD [150239]<br>count at <unknown>:0"];
150240 [labelType="html" label="MapPartitionsRDD [150240]<br>count at <unknown>:0"];
}
subgraph cluster363018 {
label="WholeStageCodegen (1)";
150241 [labelType="html" label="MapPartitionsRDD [150241]<br>count at <unknown>:0"];
}
subgraph cluster363024 {
label="mapPartitionsInternal";
150242 [labelType="html" label="MapPartitionsRDD [150242]<br>count at <unknown>:0"];
}
subgraph cluster363025 {
label="mapPartitionsInternal";
150243 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#14337219, supplier_id#14337220, entity_name#14337221, city#14337222, state#14337223, country#14337224, supplier_type#14337225, declaring_supplier_id#14337226, threshold#14337229, create_date#14337230]\n +- Filter isnull(canonical_id#14337227)\n +- InMemoryTableScan [brand_context_id#14337219, canonical_id#14337227, city#14337222, country#14337224, create_date#14337230, declaring_supplier_id#14337226, entity_name#14337221, state#14337223, supplier_id#14337220, supplier_type#14337225, threshold#14337229], [isnull(canonical_id#14337227)]\n +- InMemoryRelation [brand_context_id#14337219, supplier_id#14337220, entity_name#14337221, city#14337222, state#14337223, country#14337224, supplier_type#14337225, declaring_supplier_id#14337226, canonical_id#14337227, is_primary#14337228, threshold#14337229, create_date#14337230], StorageLevel(disk, memory, deserialized, 1 replicas)\n +- *(1) Scan JDBCRelation((\n SEL... [150243] [Cached]<br>count at <unknown>:0"];
}
}
150226->150227;
150227->150228;
150228->150229;
150229->150238;
150238->150239;
150239->150240;
150240->150241;
150241->150242;
150242->150243;
}
150229
150243