digraph G {
subgraph clusterstage_30898 {
label="Stage 30898";
132278 [labelType="html" label="JDBCRDD [132278]<br>cache at <unknown>:0"];
subgraph cluster328571 {
label="WholeStageCodegen (1)";
132279 [labelType="html" label="MapPartitionsRDD [132279]<br>count at <unknown>:0"];
}
subgraph cluster328573 {
label="mapPartitionsInternal";
132280 [labelType="html" label="MapPartitionsRDD [132280]<br>count at <unknown>:0"];
}
subgraph cluster328574 {
label="mapPartitionsInternal";
132281 [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#13212252,supplier_id#13212253,entity_name#13212254,city#13212255,state#13212256,country#13212257,supplier_type#13212258,declaring_supplier_id#13212259,canonical_id#13212260,is_primary#13212261,threshold#13212262,create_date#13212263] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [132281] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster328631 {
label="InMemoryTableScan";
132302 [labelType="html" label="MapPartitionsRDD [132302]<br>count at <unknown>:0"];
132303 [labelType="html" label="MapPartitionsRDD [132303]<br>count at <unknown>:0"];
132304 [labelType="html" label="MapPartitionsRDD [132304]<br>count at <unknown>:0"];
}
subgraph cluster328627 {
label="WholeStageCodegen (1)";
132305 [labelType="html" label="MapPartitionsRDD [132305]<br>count at <unknown>:0"];
}
subgraph cluster328632 {
label="mapPartitionsInternal";
132306 [labelType="html" label="MapPartitionsRDD [132306]<br>count at <unknown>:0"];
}
subgraph cluster328633 {
label="mapPartitionsInternal";
132307 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#13212260)\n +- InMemoryTableScan [brand_context_id#13212252, supplier_id#13212253, canonical_id#13212260, is_primary#13212261, entity_name#13212254, city#13212255, state#13212256, country#13212257, threshold#13212262, create_date#13212263], [isnotnull(canonical_id#13212260)]\n +- InMemoryRelation [brand_context_id#13212252, supplier_id#13212253, entity_name#13212254, city#13212255, state#13212256, country#13212257, supplier_type#13212258, declaring_supplier_id#13212259, canonical_id#13212260, is_primary#13212261, threshold#13212262, create_date#13212263], 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 ... [132307] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster328639 {
label="InMemoryTableScan";
132308 [labelType="html" label="MapPartitionsRDD [132308]<br>count at <unknown>:0"];
132309 [labelType="html" label="MapPartitionsRDD [132309]<br>count at <unknown>:0"];
132310 [labelType="html" label="MapPartitionsRDD [132310]<br>count at <unknown>:0"];
}
subgraph cluster328635 {
label="WholeStageCodegen (1)";
132311 [labelType="html" label="MapPartitionsRDD [132311]<br>count at <unknown>:0"];
}
subgraph cluster328634 {
label="Exchange";
132312 [labelType="html" label="MapPartitionsRDD [132312]<br>count at <unknown>:0"];
}
}
132278->132279;
132279->132280;
132280->132281;
132281->132302;
132302->132303;
132303->132304;
132304->132305;
132305->132306;
132306->132307;
132307->132308;
132308->132309;
132309->132310;
132310->132311;
132311->132312;
}
132281
132307