MCPcopy Create free account
hub / github.com/apache/arrow / operator()

Method operator()

cpp/src/arrow/acero/sorted_merge_node.cc:241–253  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

239
240struct InputStateComparator {
241 bool operator()(const std::shared_ptr<InputState>& lhs,
242 const std::shared_ptr<InputState>& rhs) const {
243 // True if lhs is ahead of time of rhs
244 if (lhs->Finished()) {
245 return false;
246 }
247 if (rhs->Finished()) {
248 return false;
249 }
250 time_unit_t lFirst = lhs->GetLatestTime();
251 time_unit_t rFirst = rhs->GetLatestTime();
252 return lFirst > rFirst;
253 }
254};
255
256class SortedMergeNode : public ExecNode {

Callers

nothing calls this directly

Calls 2

FinishedMethod · 0.45
GetLatestTimeMethod · 0.45

Tested by

no test coverage detected