digraph G {
subgraph clusterstage_36236 {
label="Stage 36236";
157374 [labelType="html" label="JDBCRDD [157374]<br>cache at <unknown>:0"];
subgraph cluster379499 {
label="WholeStageCodegen (1)";
157375 [labelType="html" label="MapPartitionsRDD [157375]<br>count at <unknown>:0"];
}
subgraph cluster379501 {
label="mapPartitionsInternal";
157376 [labelType="html" label="MapPartitionsRDD [157376]<br>count at <unknown>:0"];
}
subgraph cluster379502 {
label="mapPartitionsInternal";
157377 [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#14895460,supplier_id#14895461,entity_name#14895462,city#14895463,state#14895464,country#14895465,supplier_type#14895466,declaring_supplier_id#14895467,canonical_id#14895468,is_primary#14895469,threshold#14895470,create_date#14895471] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [157377] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster379559 {
label="InMemoryTableScan";
157398 [labelType="html" label="MapPartitionsRDD [157398]<br>count at <unknown>:0"];
157399 [labelType="html" label="MapPartitionsRDD [157399]<br>count at <unknown>:0"];
157400 [labelType="html" label="MapPartitionsRDD [157400]<br>count at <unknown>:0"];
}
subgraph cluster379555 {
label="WholeStageCodegen (1)";
157401 [labelType="html" label="MapPartitionsRDD [157401]<br>count at <unknown>:0"];
}
subgraph cluster379560 {
label="mapPartitionsInternal";
157402 [labelType="html" label="MapPartitionsRDD [157402]<br>count at <unknown>:0"];
}
subgraph cluster379561 {
label="mapPartitionsInternal";
157403 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#14895468)\n +- InMemoryTableScan [brand_context_id#14895460, supplier_id#14895461, canonical_id#14895468, is_primary#14895469, entity_name#14895462, city#14895463, state#14895464, country#14895465, threshold#14895470, create_date#14895471], [isnotnull(canonical_id#14895468)]\n +- InMemoryRelation [brand_context_id#14895460, supplier_id#14895461, entity_name#14895462, city#14895463, state#14895464, country#14895465, supplier_type#14895466, declaring_supplier_id#14895467, canonical_id#14895468, is_primary#14895469, threshold#14895470, create_date#14895471], 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 ... [157403] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster379567 {
label="InMemoryTableScan";
157404 [labelType="html" label="MapPartitionsRDD [157404]<br>count at <unknown>:0"];
157405 [labelType="html" label="MapPartitionsRDD [157405]<br>count at <unknown>:0"];
157406 [labelType="html" label="MapPartitionsRDD [157406]<br>count at <unknown>:0"];
}
subgraph cluster379563 {
label="WholeStageCodegen (1)";
157407 [labelType="html" label="MapPartitionsRDD [157407]<br>count at <unknown>:0"];
}
subgraph cluster379562 {
label="Exchange";
157408 [labelType="html" label="MapPartitionsRDD [157408]<br>count at <unknown>:0"];
}
}
157374->157375;
157375->157376;
157376->157377;
157377->157398;
157398->157399;
157399->157400;
157400->157401;
157401->157402;
157402->157403;
157403->157404;
157404->157405;
157405->157406;
157406->157407;
157407->157408;
}
157377
157403