digraph G {
subgraph clusterstage_1351 {
label="Stage 1351";
4657 [labelType="html" label="JDBCRDD [4657]<br>cache at <unknown>:0"];
subgraph cluster10849 {
label="WholeStageCodegen (1)";
4658 [labelType="html" label="MapPartitionsRDD [4658]<br>count at <unknown>:0"];
}
subgraph cluster10851 {
label="mapPartitionsInternal";
4659 [labelType="html" label="MapPartitionsRDD [4659]<br>count at <unknown>:0"];
}
subgraph cluster10852 {
label="mapPartitionsInternal";
4660 [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#321329,supplier_id#321330,entity_name#321331,city#321332,state#321333,country#321334,supplier_type#321335,declaring_supplier_id#321336,canonical_id#321337,is_primary#321338,threshold#321339,create_date#321340] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [4660] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster10884 {
label="InMemoryTableScan";
4669 [labelType="html" label="MapPartitionsRDD [4669]<br>count at <unknown>:0"];
4670 [labelType="html" label="MapPartitionsRDD [4670]<br>count at <unknown>:0"];
4671 [labelType="html" label="MapPartitionsRDD [4671]<br>count at <unknown>:0"];
}
subgraph cluster10879 {
label="WholeStageCodegen (1)";
4672 [labelType="html" label="MapPartitionsRDD [4672]<br>count at <unknown>:0"];
}
subgraph cluster10885 {
label="mapPartitionsInternal";
4673 [labelType="html" label="MapPartitionsRDD [4673]<br>count at <unknown>:0"];
}
subgraph cluster10886 {
label="mapPartitionsInternal";
4674 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [brand_context_id#321329, supplier_id#321330, entity_name#321331, city#321332, state#321333, country#321334, supplier_type#321335, declaring_supplier_id#321336, threshold#321339, create_date#321340]\n +- Filter isnull(canonical_id#321337)\n +- InMemoryTableScan [brand_context_id#321329, canonical_id#321337, city#321332, country#321334, create_date#321340, declaring_supplier_id#321336, entity_name#321331, state#321333, supplier_id#321330, supplier_type#321335, threshold#321339], [isnull(canonical_id#321337)]\n +- InMemoryRelation [brand_context_id#321329, supplier_id#321330, entity_name#321331, city#321332, state#321333, country#321334, supplier_type#321335, declaring_supplier_id#321336, canonical_id#321337, is_primary#321338, threshold#321339, create_date#321340], StorageLevel(disk, memory, deserialized, 1 replicas)\n +- *(1) Scan JDBCRelation((\n SELECT DISTINCT\n v.brand_context_id,\n v.sup... [4674] [Cached]<br>count at <unknown>:0"];
}
}
4657->4658;
4658->4659;
4659->4660;
4660->4669;
4669->4670;
4670->4671;
4671->4672;
4672->4673;
4673->4674;
}
4660
4674