digraph G {
subgraph clusterstage_1300 {
label="Stage 1300";
4467 [labelType="html" label="JDBCRDD [4467]<br>cache at <unknown>:0"];
subgraph cluster10394 {
label="WholeStageCodegen (1)";
4468 [labelType="html" label="MapPartitionsRDD [4468]<br>count at <unknown>:0"];
}
subgraph cluster10396 {
label="mapPartitionsInternal";
4469 [labelType="html" label="MapPartitionsRDD [4469]<br>count at <unknown>:0"];
}
subgraph cluster10397 {
label="mapPartitionsInternal";
4470 [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#313924,supplier_id#313925,entity_name#313926,city#313927,state#313928,country#313929,supplier_type#313930,declaring_supplier_id#313931,canonical_id#313932,is_primary#313933,threshold#313934,create_date#313935] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [4470] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster10454 {
label="InMemoryTableScan";
4491 [labelType="html" label="MapPartitionsRDD [4491]<br>count at <unknown>:0"];
4492 [labelType="html" label="MapPartitionsRDD [4492]<br>count at <unknown>:0"];
4493 [labelType="html" label="MapPartitionsRDD [4493]<br>count at <unknown>:0"];
}
subgraph cluster10450 {
label="WholeStageCodegen (1)";
4494 [labelType="html" label="MapPartitionsRDD [4494]<br>count at <unknown>:0"];
}
subgraph cluster10455 {
label="mapPartitionsInternal";
4495 [labelType="html" label="MapPartitionsRDD [4495]<br>count at <unknown>:0"];
}
subgraph cluster10456 {
label="mapPartitionsInternal";
4496 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#313932)\n +- InMemoryTableScan [brand_context_id#313924, supplier_id#313925, canonical_id#313932, is_primary#313933, entity_name#313926, city#313927, state#313928, country#313929, threshold#313934, create_date#313935], [isnotnull(canonical_id#313932)]\n +- InMemoryRelation [brand_context_id#313924, supplier_id#313925, entity_name#313926, city#313927, state#313928, country#313929, supplier_type#313930, declaring_supplier_id#313931, canonical_id#313932, is_primary#313933, threshold#313934, create_date#313935], 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... [4496] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster10462 {
label="InMemoryTableScan";
4497 [labelType="html" label="MapPartitionsRDD [4497]<br>count at <unknown>:0"];
4498 [labelType="html" label="MapPartitionsRDD [4498]<br>count at <unknown>:0"];
4499 [labelType="html" label="MapPartitionsRDD [4499]<br>count at <unknown>:0"];
}
subgraph cluster10458 {
label="WholeStageCodegen (1)";
4500 [labelType="html" label="MapPartitionsRDD [4500]<br>count at <unknown>:0"];
}
subgraph cluster10457 {
label="Exchange";
4501 [labelType="html" label="MapPartitionsRDD [4501]<br>count at <unknown>:0"];
}
}
4467->4468;
4468->4469;
4469->4470;
4470->4491;
4491->4492;
4492->4493;
4493->4494;
4494->4495;
4495->4496;
4496->4497;
4497->4498;
4498->4499;
4499->4500;
4500->4501;
}
4470
4496