digraph G {
subgraph clusterstage_1355 {
label="Stage 1355";
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 cluster10909 {
label="InMemoryTableScan";
4681 [labelType="html" label="MapPartitionsRDD [4681]<br>count at <unknown>:0"];
4682 [labelType="html" label="MapPartitionsRDD [4682]<br>count at <unknown>:0"];
4683 [labelType="html" label="MapPartitionsRDD [4683]<br>count at <unknown>:0"];
}
subgraph cluster10905 {
label="WholeStageCodegen (1)";
4684 [labelType="html" label="MapPartitionsRDD [4684]<br>count at <unknown>:0"];
}
subgraph cluster10910 {
label="mapPartitionsInternal";
4685 [labelType="html" label="MapPartitionsRDD [4685]<br>count at <unknown>:0"];
}
subgraph cluster10911 {
label="mapPartitionsInternal";
4686 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#321337)\n +- InMemoryTableScan [brand_context_id#321329, supplier_id#321330, canonical_id#321337, is_primary#321338, entity_name#321331, city#321332, state#321333, country#321334, threshold#321339, create_date#321340], [isnotnull(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.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_prima... [4686] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster10917 {
label="InMemoryTableScan";
4687 [labelType="html" label="MapPartitionsRDD [4687]<br>count at <unknown>:0"];
4688 [labelType="html" label="MapPartitionsRDD [4688]<br>count at <unknown>:0"];
4689 [labelType="html" label="MapPartitionsRDD [4689]<br>count at <unknown>:0"];
}
subgraph cluster10913 {
label="WholeStageCodegen (1)";
4690 [labelType="html" label="MapPartitionsRDD [4690]<br>count at <unknown>:0"];
}
subgraph cluster10912 {
label="Exchange";
4691 [labelType="html" label="MapPartitionsRDD [4691]<br>count at <unknown>:0"];
}
}
4657->4658;
4658->4659;
4659->4660;
4660->4681;
4681->4682;
4682->4683;
4683->4684;
4684->4685;
4685->4686;
4686->4687;
4687->4688;
4688->4689;
4689->4690;
4690->4691;
}
4660
4686