MCPcopy Create free account
hub / github.com/MaterializeInc/materialize / is_streamable

Method is_streamable

src/expr/src/relation.rs:3569–3571  ·  view source on GitHub ↗

True if the finishing does not require an ORDER BY. LIMIT and OFFSET without an ORDER BY _are_ streamable: without an explicit ordering we will skip an arbitrary bag of elements and return the first arbitrary elements in the remaining bag. The result semantics are still correct but maybe surprising for some users.

(&self, arity: usize)

Source from the content-addressed store, hash-verified

3567 /// the first arbitrary elements in the remaining bag. The result semantics
3568 /// are still correct but maybe surprising for some users.
3569 pub fn is_streamable(&self, arity: usize) -> bool {
3570 self.order_by.is_empty() && self.project.iter().copied().eq(0..arity)
3571 }
3572}
3573
3574impl RowSetFinishing<NonNeg<i64>, usize> {

Callers 1

process_peekMethod · 0.80

Calls 3

is_emptyMethod · 0.45
eqMethod · 0.45
iterMethod · 0.45

Tested by

no test coverage detected