MCPcopy Create free account
hub / github.com/apache/arrow / CheckEnded

Method CheckEnded

cpp/src/arrow/acero/asof_join_node.cc:1057–1063  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1055 }
1056
1057 bool CheckEnded() {
1058 if (state_.at(0)->Finished()) {
1059 EndFromProcessThread();
1060 return false;
1061 }
1062 return true;
1063 }
1064
1065 bool Process() {
1066 std::lock_guard<std::mutex> guard(gate_);

Callers

nothing calls this directly

Calls 1

FinishedMethod · 0.45

Tested by

no test coverage detected