digraph G {
subgraph clusterstage_28808 {
label="Stage 28808";
124950 [labelType="html" label="JDBCRDD [124950]<br>cache at <unknown>:0"];
subgraph cluster311783 {
label="WholeStageCodegen (1)";
124951 [labelType="html" label="MapPartitionsRDD [124951]<br>count at <unknown>:0"];
}
subgraph cluster311785 {
label="mapPartitionsInternal";
124952 [labelType="html" label="MapPartitionsRDD [124952]<br>count at <unknown>:0"];
}
subgraph cluster311786 {
label="mapPartitionsInternal";
124953 [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#12589968,supplier_id#12589969,entity_name#12589970,city#12589971,state#12589972,country#12589973,supplier_type#12589974,declaring_supplier_id#12589975,canonical_id#12589976,is_primary#12589977,threshold#12589978,create_date#12589979] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [124953] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster311843 {
label="InMemoryTableScan";
124974 [labelType="html" label="MapPartitionsRDD [124974]<br>count at <unknown>:0"];
124975 [labelType="html" label="MapPartitionsRDD [124975]<br>count at <unknown>:0"];
124976 [labelType="html" label="MapPartitionsRDD [124976]<br>count at <unknown>:0"];
}
subgraph cluster311839 {
label="WholeStageCodegen (1)";
124977 [labelType="html" label="MapPartitionsRDD [124977]<br>count at <unknown>:0"];
}
subgraph cluster311844 {
label="mapPartitionsInternal";
124978 [labelType="html" label="MapPartitionsRDD [124978]<br>count at <unknown>:0"];
}
subgraph cluster311845 {
label="mapPartitionsInternal";
124979 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#12589976)\n +- InMemoryTableScan [brand_context_id#12589968, supplier_id#12589969, canonical_id#12589976, is_primary#12589977, entity_name#12589970, city#12589971, state#12589972, country#12589973, threshold#12589978, create_date#12589979], [isnotnull(canonical_id#12589976)]\n +- InMemoryRelation [brand_context_id#12589968, supplier_id#12589969, entity_name#12589970, city#12589971, state#12589972, country#12589973, supplier_type#12589974, declaring_supplier_id#12589975, canonical_id#12589976, is_primary#12589977, threshold#12589978, create_date#12589979], 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 ... [124979] [Cached]<br>count at <unknown>:0"];
}
}
124950->124951;
124951->124952;
124952->124953;
124953->124974;
124974->124975;
124975->124976;
124976->124977;
124977->124978;
124978->124979;
}
124953
124979