evalMeasures is to fill measure values
()
| 167 | |
| 168 | // evalMeasures is to fill measure values |
| 169 | func (e *BatchExecutorImpl) evalMeasures() { |
| 170 | // measure evaluation. |
| 171 | e.qc.doProfile(func() { |
| 172 | measureExprRootAction := e.qc.OOPK.currentBatch.makeWriteToMeasureVectorAction(e.qc.OOPK.AggregateType, e.qc.OOPK.MeasureBytes) |
| 173 | e.qc.OOPK.currentBatch.processExpression(e.qc.OOPK.Measure, nil, e.qc.TableScanners, e.qc.OOPK.foreignTables, e.stream, e.qc.Device, measureExprRootAction) |
| 174 | e.qc.reportTimingForCurrentBatch(e.stream, &e.start, measureEvalTiming) |
| 175 | }, "measure", e.stream) |
| 176 | } |
| 177 | |
| 178 | // evalDimensions is to fill dimension values |
| 179 | func (e *BatchExecutorImpl) evalDimensions(prevResultSize int) { |
no test coverage detected