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

Method addRemoteSplits

bolt/exec/tests/MultiFragmentTest.cpp:184–191  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

182 }
183
184 static void addRemoteSplits(
185 const std::shared_ptr<Task>& task,
186 const std::vector<std::string>& remoteTaskIds) {
187 for (auto& taskId : remoteTaskIds) {
188 task->addSplit("0", remoteSplit(taskId));
189 }
190 task->noMoreSplits("0");
191 }
192
193 std::shared_ptr<Task> assertQuery(
194 const core::PlanNodePtr& plan,

Callers

nothing calls this directly

Calls 2

addSplitMethod · 0.45
noMoreSplitsMethod · 0.45

Tested by

no test coverage detected