digraph G {
subgraph clusterstage_1395 {
label="Stage 1395";
4809 [labelType="html" label="JDBCRDD [4809]<br>cache at <unknown>:0"];
subgraph cluster11213 {
label="WholeStageCodegen (1)";
4810 [labelType="html" label="MapPartitionsRDD [4810]<br>count at <unknown>:0"];
}
subgraph cluster11215 {
label="mapPartitionsInternal";
4811 [labelType="html" label="MapPartitionsRDD [4811]<br>count at <unknown>:0"];
}
subgraph cluster11216 {
label="mapPartitionsInternal";
4812 [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#327253,supplier_id#327254,entity_name#327255,city#327256,state#327257,country#327258,supplier_type#327259,declaring_supplier_id#327260,canonical_id#327261,is_primary#327262,threshold#327263,create_date#327264] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [4812] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster11248 {
label="InMemoryTableScan";
4821 [labelType="html" label="MapPartitionsRDD [4821]<br>count at <unknown>:0"];
4822 [labelType="html" label="MapPartitionsRDD [4822]<br>count at <unknown>:0"];
4823 [labelType="html" label="MapPartitionsRDD [4823]<br>count at <unknown>:0"];
}
subgraph cluster11243 {
label="WholeStageCodegen (1)";
4824 [labelType="html" label="MapPartitionsRDD [4824]<br>count at <unknown>:0"];
}
subgraph cluster11249 {
label="mapPartitionsInternal";
4825 [labelType="html" label="MapPartitionsRDD [4825]<br>count at <unknown>:0"];
}
subgraph cluster11250 {
label="mapPartitionsInternal";
4826 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#327253, supplier_id#327254, entity_name#327255, city#327256, state#327257, country#327258, supplier_type#327259, declaring_supplier_id#327260, threshold#327263, create_date#327264]\n +- Filter isnull(canonical_id#327261)\n +- InMemoryTableScan [brand_context_id#327253, canonical_id#327261, city#327256, country#327258, create_date#327264, declaring_supplier_id#327260, entity_name#327255, state#327257, supplier_id#327254, supplier_type#327259, threshold#327263], [isnull(canonical_id#327261)]\n +- InMemoryRelation [brand_context_id#327253, supplier_id#327254, entity_name#327255, city#327256, state#327257, country#327258, supplier_type#327259, declaring_supplier_id#327260, canonical_id#327261, is_primary#327262, threshold#327263, create_date#327264], StorageLevel(disk, memory, deserialized, 1 replicas)\n +- *(1) Scan JDBCRelation((\n SELECT DISTINCT\n v.brand_context_id,\n v.sup... [4826] [Cached]<br>count at <unknown>:0"];
}
}
4809->4810;
4810->4811;
4811->4812;
4812->4821;
4821->4822;
4822->4823;
4823->4824;
4824->4825;
4825->4826;
}
4812
4826