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

Function notify

bolt/exec/LocalPartition.cpp:35–39  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

33namespace bytedance::bolt::exec {
34namespace {
35void notify(std::vector<ContinuePromise>& promises) {
36 for (auto& promise : promises) {
37 promise.setValue();
38 }
39}
40} // namespace
41
42bool LocalExchangeMemoryManager::increaseMemoryUsage(

Callers 15

getDataMethod · 0.85
setHashTableMethod · 0.85
probeFinishedMethod · 0.85
noMoreProducersMethod · 0.85
enqueueMethod · 0.85
noMoreDataMethod · 0.85
nextMethod · 0.85
abortMethod · 0.85
closeMethod · 0.85
cancelMethod · 0.85

Calls 1

setValueMethod · 0.45

Tested by 2

setBuildFinishedMethod · 0.68
setNumRowsMethod · 0.68