digraph G {
subgraph clusterstage_26840 {
label="Stage 26840";
118144 [labelType="html" label="JDBCRDD [118144]<br>cache at <unknown>:0"];
subgraph cluster296091 {
label="WholeStageCodegen (1)";
118145 [labelType="html" label="MapPartitionsRDD [118145]<br>count at <unknown>:0"];
}
subgraph cluster296093 {
label="mapPartitionsInternal";
118146 [labelType="html" label="MapPartitionsRDD [118146]<br>count at <unknown>:0"];
}
subgraph cluster296094 {
label="mapPartitionsInternal";
118147 [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#12045056,supplier_id#12045057,entity_name#12045058,city#12045059,state#12045060,country#12045061,supplier_type#12045062,declaring_supplier_id#12045063,canonical_id#12045064,is_primary#12045065,threshold#12045066,create_date#12045067] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [118147] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster296151 {
label="InMemoryTableScan";
118168 [labelType="html" label="MapPartitionsRDD [118168]<br>count at <unknown>:0"];
118169 [labelType="html" label="MapPartitionsRDD [118169]<br>count at <unknown>:0"];
118170 [labelType="html" label="MapPartitionsRDD [118170]<br>count at <unknown>:0"];
}
subgraph cluster296147 {
label="WholeStageCodegen (1)";
118171 [labelType="html" label="MapPartitionsRDD [118171]<br>count at <unknown>:0"];
}
subgraph cluster296152 {
label="mapPartitionsInternal";
118172 [labelType="html" label="MapPartitionsRDD [118172]<br>count at <unknown>:0"];
}
subgraph cluster296153 {
label="mapPartitionsInternal";
118173 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#12045064)\n +- InMemoryTableScan [brand_context_id#12045056, supplier_id#12045057, canonical_id#12045064, is_primary#12045065, entity_name#12045058, city#12045059, state#12045060, country#12045061, threshold#12045066, create_date#12045067], [isnotnull(canonical_id#12045064)]\n +- InMemoryRelation [brand_context_id#12045056, supplier_id#12045057, entity_name#12045058, city#12045059, state#12045060, country#12045061, supplier_type#12045062, declaring_supplier_id#12045063, canonical_id#12045064, is_primary#12045065, threshold#12045066, create_date#12045067], 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 ... [118173] [Cached]<br>count at <unknown>:0"];
}
}
118144->118145;
118145->118146;
118146->118147;
118147->118168;
118168->118169;
118169->118170;
118170->118171;
118171->118172;
118172->118173;
}
118147
118173