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

Method callResetPartition

bolt/exec/Window.cpp:531–546  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

529}
530
531void Window::callResetPartition() {
532 MicrosecondTimer timer(&extractColumnTimeUs_);
533 partitionOffset_ = 0;
534 peerStartRow_ = 0;
535 peerEndRow_ = 0;
536 currentPartition_ = nullptr;
537 bool hasNextPartition = false;
538 hasNextPartition = windowBuild_->hasNextPartition();
539
540 if (hasNextPartition) {
541 currentPartition_ = windowBuild_->nextPartition();
542 for (int i = 0; i < windowFunctions_.size(); i++) {
543 windowFunctions_[i]->resetPartition(currentPartition_.get());
544 }
545 }
546}
547
548namespace {
549

Callers

nothing calls this directly

Calls 5

hasNextPartitionMethod · 0.45
nextPartitionMethod · 0.45
sizeMethod · 0.45
resetPartitionMethod · 0.45
getMethod · 0.45

Tested by

no test coverage detected