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

Method CurrentEmpty

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

true when the queue is empty and, when memo may have future entries (the case of a positive tolerance), when the memo is empty. used when checking whether RHS is up to date with LHS. NOTE: The emptiness must be decided by a single call to Empty() in caller, due to the potential race with Push(), see GH-41614.

Source from the content-addressed store, hash-verified

555 // NOTE: The emptiness must be decided by a single call to Empty() in caller, due to the
556 // potential race with Push(), see GH-41614.
557 bool CurrentEmpty(bool empty) const {
558 return memo_.no_future_ ? empty : (memo_.times_.empty() && empty);
559 }
560
561 // in case memo may not have future entries (the case of a non-positive tolerance),
562 // returns the latest time (which is current); otherwise, returns the current time.

Callers 1

UpdateRhsMethod · 0.80

Calls 1

emptyMethod · 0.45

Tested by

no test coverage detected