MCPcopy Create free account
hub / github.com/bytedance/bolt / accumulator

Method accumulator

bolt/exec/SortedAggregations.cpp:165–185  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

163}
164
165Accumulator SortedAggregations::accumulator() const {
166 return {
167 false,
168 sizeof(RowPointers),
169 false,
170 1,
171 ARRAY(VARBINARY()),
172 UNKNOWN(),
173 [this](folly::Range<char**> groups, VectorPtr& result) {
174 extractForSpill(groups, result);
175 },
176 [this](folly::Range<char**> groups, VectorPtr& result) {
177 BOLT_UNREACHABLE();
178 },
179 [this](folly::Range<char**> groups) {
180 for (auto* group : groups) {
181 auto* accumulator = reinterpret_cast<RowPointers*>(group + offset_);
182 accumulator->free(*allocator_);
183 }
184 }};
185}
186
187void SortedAggregations::extractForSpill(
188 folly::Range<char**> groups,

Callers 3

accumulatorsMethod · 0.45
makeRowContainerMethod · 0.45

Calls 3

ARRAYFunction · 0.85
UNKNOWNFunction · 0.85
freeMethod · 0.45

Tested by

no test coverage detected