digraph G {
subgraph clusterstage_41935 {
label="Stage 41935";
183915 [labelType="html" label="JDBCRDD [183915]<br>cache at <unknown>:0"];
subgraph cluster434005 {
label="WholeStageCodegen (1)";
183916 [labelType="html" label="MapPartitionsRDD [183916]<br>count at <unknown>:0"];
}
subgraph cluster434007 {
label="mapPartitionsInternal";
183917 [labelType="html" label="MapPartitionsRDD [183917]<br>count at <unknown>:0"];
}
subgraph cluster434008 {
label="mapPartitionsInternal";
183918 [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#16731089,supplier_id#16731090,entity_name#16731091,city#16731092,state#16731093,country#16731094,supplier_type#16731095,declaring_supplier_id#16731096,canonical_id#16731097,is_primary#16731098,threshold#16731099,create_date#16731100] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [183918] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster434065 {
label="InMemoryTableScan";
183939 [labelType="html" label="MapPartitionsRDD [183939]<br>count at <unknown>:0"];
183940 [labelType="html" label="MapPartitionsRDD [183940]<br>count at <unknown>:0"];
183941 [labelType="html" label="MapPartitionsRDD [183941]<br>count at <unknown>:0"];
}
subgraph cluster434061 {
label="WholeStageCodegen (1)";
183942 [labelType="html" label="MapPartitionsRDD [183942]<br>count at <unknown>:0"];
}
subgraph cluster434066 {
label="mapPartitionsInternal";
183943 [labelType="html" label="MapPartitionsRDD [183943]<br>count at <unknown>:0"];
}
subgraph cluster434067 {
label="mapPartitionsInternal";
183944 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#16731097)\n +- InMemoryTableScan [brand_context_id#16731089, supplier_id#16731090, canonical_id#16731097, is_primary#16731098, entity_name#16731091, city#16731092, state#16731093, country#16731094, threshold#16731099, create_date#16731100], [isnotnull(canonical_id#16731097)]\n +- InMemoryRelation [brand_context_id#16731089, supplier_id#16731090, entity_name#16731091, city#16731092, state#16731093, country#16731094, supplier_type#16731095, declaring_supplier_id#16731096, canonical_id#16731097, is_primary#16731098, threshold#16731099, create_date#16731100], 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 ... [183944] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster434073 {
label="InMemoryTableScan";
183945 [labelType="html" label="MapPartitionsRDD [183945]<br>count at <unknown>:0"];
183946 [labelType="html" label="MapPartitionsRDD [183946]<br>count at <unknown>:0"];
183947 [labelType="html" label="MapPartitionsRDD [183947]<br>count at <unknown>:0"];
}
subgraph cluster434069 {
label="WholeStageCodegen (1)";
183948 [labelType="html" label="MapPartitionsRDD [183948]<br>count at <unknown>:0"];
}
subgraph cluster434068 {
label="Exchange";
183949 [labelType="html" label="MapPartitionsRDD [183949]<br>count at <unknown>:0"];
}
}
183915->183916;
183916->183917;
183917->183918;
183918->183939;
183939->183940;
183940->183941;
183941->183942;
183942->183943;
183943->183944;
183944->183945;
183945->183946;
183946->183947;
183947->183948;
183948->183949;
}
183918
183944