| 288 | } |
| 289 | |
| 290 | private void getLogToDataMap(Map<PhysicalOperator, DataBag> phyToDataMap) { |
| 291 | logToDataMap.clear(); |
| 292 | for (Operator lo : logToPhyMap.keySet()) { |
| 293 | if (logToPhyMap.get(lo) != null) |
| 294 | logToDataMap.put(lo, phyToDataMap.get(logToPhyMap.get(lo))); |
| 295 | } |
| 296 | |
| 297 | // set the LO-to-Data mapping for the ForEach inner plans |
| 298 | for (Map.Entry<LOForEach, Map<LogicalRelationalOperator, DataBag>> entry : forEachInnerLogToDataMap.entrySet()) { |
| 299 | entry.getValue().clear(); |
| 300 | for (Map.Entry<LogicalRelationalOperator, PhysicalOperator> innerEntry : forEachInnerLogToPhyMap.get(entry.getKey()).entrySet()) { |
| 301 | entry.getValue().put(innerEntry.getKey(), phyToDataMap.get(innerEntry.getValue())); |
| 302 | } |
| 303 | } |
| 304 | } |
| 305 | |
| 306 | private void setLoadDataMap() { |
| 307 | // This function sets up the LO-TO-Data map, eq. class, and lineage for the base data used in the coming runner |