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

Function sample_rows_from

src/clusterd-test-driver/src/data.rs:141–143  ·  view source on GitHub ↗

Like [`sample_rows`], but ids run `start..start + n`. Successive batches with disjoint id ranges produce distinct rows that never consolidate with each other, so a downstream count equals the total rows written.

(start: u64, n: u64, pad: usize)

Source from the content-addressed store, hash-verified

139/// disjoint id ranges produce distinct rows that never consolidate with each
140/// other, so a downstream count equals the total rows written.
141pub fn sample_rows_from(start: u64, n: u64, pad: usize) -> Vec<Row> {
142 synth_rows(&sample_desc(), start, n, pad)
143}
144
145/// Writes `rows` to `shard` at `ts`, advancing `upper` to `ts+1`. All rows are
146/// inserted with diff `+1`. Returns once the append succeeds.

Callers 1

sample_rowsFunction · 0.85

Calls 2

synth_rowsFunction · 0.85
sample_descFunction · 0.85

Tested by

no test coverage detected