digraph G {
subgraph clusterstage_43902 {
label="Stage 43902";
190721 [labelType="html" label="JDBCRDD [190721]<br>cache at <unknown>:0"];
subgraph cluster449697 {
label="WholeStageCodegen (1)";
190722 [labelType="html" label="MapPartitionsRDD [190722]<br>count at <unknown>:0"];
}
subgraph cluster449699 {
label="mapPartitionsInternal";
190723 [labelType="html" label="MapPartitionsRDD [190723]<br>count at <unknown>:0"];
}
subgraph cluster449700 {
label="mapPartitionsInternal";
190724 [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#17276001,supplier_id#17276002,entity_name#17276003,city#17276004,state#17276005,country#17276006,supplier_type#17276007,declaring_supplier_id#17276008,canonical_id#17276009,is_primary#17276010,threshold#17276011,create_date#17276012] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [190724] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster449757 {
label="InMemoryTableScan";
190745 [labelType="html" label="MapPartitionsRDD [190745]<br>count at <unknown>:0"];
190746 [labelType="html" label="MapPartitionsRDD [190746]<br>count at <unknown>:0"];
190747 [labelType="html" label="MapPartitionsRDD [190747]<br>count at <unknown>:0"];
}
subgraph cluster449753 {
label="WholeStageCodegen (1)";
190748 [labelType="html" label="MapPartitionsRDD [190748]<br>count at <unknown>:0"];
}
subgraph cluster449758 {
label="mapPartitionsInternal";
190749 [labelType="html" label="MapPartitionsRDD [190749]<br>count at <unknown>:0"];
}
subgraph cluster449759 {
label="mapPartitionsInternal";
190750 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#17276009)\n +- InMemoryTableScan [brand_context_id#17276001, supplier_id#17276002, canonical_id#17276009, is_primary#17276010, entity_name#17276003, city#17276004, state#17276005, country#17276006, threshold#17276011, create_date#17276012], [isnotnull(canonical_id#17276009)]\n +- InMemoryRelation [brand_context_id#17276001, supplier_id#17276002, entity_name#17276003, city#17276004, state#17276005, country#17276006, supplier_type#17276007, declaring_supplier_id#17276008, canonical_id#17276009, is_primary#17276010, threshold#17276011, create_date#17276012], 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 ... [190750] [Cached]<br>count at <unknown>:0"];
}
}
190721->190722;
190722->190723;
190723->190724;
190724->190745;
190745->190746;
190746->190747;
190747->190748;
190748->190749;
190749->190750;
}
190724
190750