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

Method setNumRows

bolt/exec/tests/CustomJoinTest.cpp:66–75  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

64class CustomJoinBridge : public JoinBridge {
65 public:
66 void setNumRows(std::optional<int32_t> numRows) {
67 std::vector<ContinuePromise> promises;
68 {
69 std::lock_guard<std::mutex> l(mutex_);
70 BOLT_CHECK(!numRows_.has_value(), "setNumRows may be called only once");
71 numRows_ = numRows;
72 promises = std::move(promises_);
73 }
74 notify(std::move(promises));
75 }
76
77 std::optional<int32_t> numRowsOrFuture(ContinueFuture* future) {
78 std::lock_guard<std::mutex> l(mutex_);

Callers 1

noMoreInputMethod · 0.45

Calls 2

notifyFunction · 0.85
has_valueMethod · 0.80

Tested by

no test coverage detected