digraph G {
subgraph clusterstage_44012 {
label="Stage 44012";
191101 [labelType="html" label="JDBCRDD [191101]<br>cache at <unknown>:0"];
subgraph cluster450607 {
label="WholeStageCodegen (1)";
191102 [labelType="html" label="MapPartitionsRDD [191102]<br>count at <unknown>:0"];
}
subgraph cluster450609 {
label="mapPartitionsInternal";
191103 [labelType="html" label="MapPartitionsRDD [191103]<br>count at <unknown>:0"];
}
subgraph cluster450610 {
label="mapPartitionsInternal";
191104 [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#17290811,supplier_id#17290812,entity_name#17290813,city#17290814,state#17290815,country#17290816,supplier_type#17290817,declaring_supplier_id#17290818,canonical_id#17290819,is_primary#17290820,threshold#17290821,create_date#17290822] PushedFilters: [], ReadSchema: struct<brand_context_id:string,supplier_id:string,entity_name:string,city:string,state:string,cou...\n [191104] [Cached]<br>count at <unknown>:0"];
}
subgraph cluster450667 {
label="InMemoryTableScan";
191125 [labelType="html" label="MapPartitionsRDD [191125]<br>count at <unknown>:0"];
191126 [labelType="html" label="MapPartitionsRDD [191126]<br>count at <unknown>:0"];
191127 [labelType="html" label="MapPartitionsRDD [191127]<br>count at <unknown>:0"];
}
subgraph cluster450663 {
label="WholeStageCodegen (1)";
191128 [labelType="html" label="MapPartitionsRDD [191128]<br>count at <unknown>:0"];
}
subgraph cluster450668 {
label="mapPartitionsInternal";
191129 [labelType="html" label="MapPartitionsRDD [191129]<br>count at <unknown>:0"];
}
subgraph cluster450669 {
label="mapPartitionsInternal";
191130 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Filter isnotnull(canonical_id#17290819)\n +- InMemoryTableScan [brand_context_id#17290811, supplier_id#17290812, canonical_id#17290819, is_primary#17290820, entity_name#17290813, city#17290814, state#17290815, country#17290816, threshold#17290821, create_date#17290822], [isnotnull(canonical_id#17290819)]\n +- InMemoryRelation [brand_context_id#17290811, supplier_id#17290812, entity_name#17290813, city#17290814, state#17290815, country#17290816, supplier_type#17290817, declaring_supplier_id#17290818, canonical_id#17290819, is_primary#17290820, threshold#17290821, create_date#17290822], 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 ... [191130] [Cached]<br>count at <unknown>:0"];
}
}
191101->191102;
191102->191103;
191103->191104;
191104->191125;
191125->191126;
191126->191127;
191127->191128;
191128->191129;
191129->191130;
}
191104
191130