| 634 | } |
| 635 | |
| 636 | Status Reset() override { |
| 637 | ARROW_DCHECK_EQ(temp_stack_.AllocatedSize(), 0); |
| 638 | rows_.Clean(); |
| 639 | rows_minibatch_.Clean(); |
| 640 | map_.cleanup(); |
| 641 | RETURN_NOT_OK(map_.init(encode_ctx_.hardware_flags, ctx_->memory_pool())); |
| 642 | // TODO: It is now assumed that the dictionaries_ are identical to the first batch |
| 643 | // throughout the grouper's lifespan so no resetting is needed. But if we want to |
| 644 | // support different dictionaries for different batches, we need to reset the |
| 645 | // dictionaries_ here. |
| 646 | return Status::OK(); |
| 647 | } |
| 648 | |
| 649 | Status Populate(const ExecSpan& batch, int64_t offset, int64_t length) override { |
| 650 | return ConsumeImpl(batch, offset, length, GrouperMode::kPopulate).status(); |
nothing calls this directly
no test coverage detected