| 131 | } |
| 132 | |
| 133 | void resetAggregateGroup() { |
| 134 | aggregate_->clear(); |
| 135 | if (aggregateInitialized_) { |
| 136 | aggregate_->destroy(folly::Range(&rawSingleGroupRow_, 1)); |
| 137 | } |
| 138 | aggregate_->initializeNewGroups( |
| 139 | &rawSingleGroupRow_, std::vector<vector_size_t>{0}); |
| 140 | aggregateInitialized_ = true; |
| 141 | } |
| 142 | |
| 143 | void apply( |
| 144 | const BufferPtr& /*peerGroupStarts*/, |
nothing calls this directly
no test coverage detected