digraph G {
subgraph clusterstage_35054 {
label="Stage 35054";
153287 [labelType="html" label="JDBCRDD [153287]<br>cache at <unknown>:0"];
subgraph cluster370015 {
label="WholeStageCodegen (1)";
153288 [labelType="html" label="MapPartitionsRDD [153288]<br>count at <unknown>:0"];
}
subgraph cluster370017 {
label="mapPartitionsInternal";
153289 [labelType="html" label="MapPartitionsRDD [153289]<br>count at <unknown>:0"];
}
subgraph cluster370018 {
label="mapPartitionsInternal";
153290 [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#14596346,supplier_id#14596347,entity_name#14596348,city#14596349,state#14596350,country#14596351,supplier_type#14596352,declaring_supplier_id#14596353,canonical_id#14596354,is_primary#14596355,threshold#14596356,create_date#14596357] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [153290] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster370075 {
label="InMemoryTableScan";
153311 [labelType="html" label="MapPartitionsRDD [153311]<br>count at <unknown>:0"];
153312 [labelType="html" label="MapPartitionsRDD [153312]<br>count at <unknown>:0"];
153313 [labelType="html" label="MapPartitionsRDD [153313]<br>count at <unknown>:0"];
}
subgraph cluster370071 {
label="WholeStageCodegen (1)";
153314 [labelType="html" label="MapPartitionsRDD [153314]<br>count at <unknown>:0"];
}
subgraph cluster370076 {
label="mapPartitionsInternal";
153315 [labelType="html" label="MapPartitionsRDD [153315]<br>count at <unknown>:0"];
}
subgraph cluster370077 {
label="mapPartitionsInternal";
153316 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#14596354)\n +- InMemoryTableScan [brand_context_id#14596346, supplier_id#14596347, canonical_id#14596354, is_primary#14596355, entity_name#14596348, city#14596349, state#14596350, country#14596351, threshold#14596356, create_date#14596357], [isnotnull(canonical_id#14596354)]\n +- InMemoryRelation [brand_context_id#14596346, supplier_id#14596347, entity_name#14596348, city#14596349, state#14596350, country#14596351, supplier_type#14596352, declaring_supplier_id#14596353, canonical_id#14596354, is_primary#14596355, threshold#14596356, create_date#14596357], 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 ... [153316] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster370083 {
label="InMemoryTableScan";
153317 [labelType="html" label="MapPartitionsRDD [153317]<br>count at <unknown>:0"];
153318 [labelType="html" label="MapPartitionsRDD [153318]<br>count at <unknown>:0"];
153319 [labelType="html" label="MapPartitionsRDD [153319]<br>count at <unknown>:0"];
}
subgraph cluster370079 {
label="WholeStageCodegen (1)";
153320 [labelType="html" label="MapPartitionsRDD [153320]<br>count at <unknown>:0"];
}
subgraph cluster370078 {
label="Exchange";
153321 [labelType="html" label="MapPartitionsRDD [153321]<br>count at <unknown>:0"];
}
}
153287->153288;
153288->153289;
153289->153290;
153290->153311;
153311->153312;
153312->153313;
153313->153314;
153314->153315;
153315->153316;
153316->153317;
153317->153318;
153318->153319;
153319->153320;
153320->153321;
}
153290
153316