StreamingAggregationOperator(OperatorContext, List, List, List, AggregationNode.Step, List, JoinCompiler) |  | 0% | | n/a | 1 | 1 | 19 | 19 | 1 | 1 |
evaluateAndFlushGroup(Page, int) |  | 0% |  | 0% | 4 | 4 | 13 | 13 | 1 | 1 |
processInput(Page) |  | 0% |  | 0% | 4 | 4 | 15 | 15 | 1 | 1 |
updateMemoryUsage() |  | 0% |  | 0% | 5 | 5 | 13 | 13 | 1 | 1 |
finish() |  | 0% |  | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
setupAggregates(AggregationNode.Step, List) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
addRowsToAggregates(Page, int, int) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
findNextGroupStart(int, Page) |  | 0% |  | 0% | 3 | 3 | 4 | 4 | 1 | 1 |
toTypes(List, List) |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
addInput(Page) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
isFinished() |  | 0% |  | 0% | 5 | 5 | 1 | 1 | 1 | 1 |
needsInput() |  | 0% |  | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
getOutput() |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
getOperatorContext() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$new$0(Type) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |