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

Method Clear

cpp/src/arrow/acero/accumulation_queue.cc:58–61  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

56}
57
58void AccumulationQueue::Clear() {
59 row_count_ = 0;
60 batches_.clear();
61}
62
63ExecBatch& AccumulationQueue::operator[](size_t i) { return batches_[i]; }
64

Callers 14

InitEncoderMethod · 0.45
ProbeSingleBatchMethod · 0.45
StopProducingImplMethod · 0.45
StopProducingImplMethod · 0.45
OnQueuedBatchesProbedMethod · 0.45
ConcurrentQueueBasicTestFunction · 0.45
AccumulationQueueMethod · 0.45
ConcatenateMethod · 0.45
BuildFinishedMethod · 0.45
CleanUpMethod · 0.45
EncodeBatchMethod · 0.45

Calls 1

clearMethod · 0.45

Tested by 1

ConcurrentQueueBasicTestFunction · 0.36