MCPcopy Create free account
hub / github.com/apache/arrow / Reset

Method Reset

cpp/src/arrow/compute/row/grouper.cc:636–647  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

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();

Callers

nothing calls this directly

Calls 5

CleanMethod · 0.80
OKFunction · 0.50
cleanupMethod · 0.45
initMethod · 0.45
memory_poolMethod · 0.45

Tested by

no test coverage detected