Struct mz_persist::indexed::encoding::ArrangementMeta

pub struct ArrangementMeta {
    pub id: Id,
    pub seal: Antichain<u64>,
    pub since: Antichain<u64>,
    pub unsealed_batches: Vec<UnsealedBatchMeta>,
    pub trace_batches: Vec<TraceBatchMeta>,
}

The metadata necessary to reconstruct an Arrangement.

Invariants:

• The unsealed_batch SeqNo ranges are sorted and non-overlapping.
• The trace_batch Descriptions are sorted, non-overlapping, and contiguous.
• Every batch’s since frontier is <= the overall trace’s since frontier.
• The compaction level of trace_batches is weakly decreasing when iterating from oldest to most recent time intervals.
• Every trace_batch’s upper is <= the overall trace’s seal frontier.

Fields

id: Id

The stream this unsealed belongs to.

seal: Antichain<u64>

Frontier this trace has been sealed up to.

since: Antichain<u64>

Compaction frontier for the batches contained in this trace. There may still be batches containing updates at times < since, but the the trace only contains correct answers for times at or in advance of this of this frontier. Readers are expected to advance any updates < since to since.

unsealed_batches: Vec<UnsealedBatchMeta>

The batches that make up the Unsealed.

trace_batches: Vec<TraceBatchMeta>

The batches that make up the Trace.

Implementations

impl ArrangementMeta

pub fn new(id: Id) -> Self

Create a new ArrangementMeta belonging to id.

pub fn validate(&self) -> Result<(), Error>

Asserts Self’s documented invariants, returning an error if any are violated.

pub fn unsealed_seqno_upper(&self) -> SeqNo

Returns an open upper bound on the seqnos contained in this unsealed.

pub fn trace_ts_upper(&self) -> Antichain<u64>

Returns an open upper bound on the timestamps of data contained in this trace.

Trait Implementations

impl Clone for ArrangementMeta

fn clone(&self) -> ArrangementMeta

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ArrangementMeta

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ArrangementMeta

fn default() -> Self

Returns the “default value” for a type.

impl From<&'_ ArrangementMeta> for ProtoArrangement

fn from(x: &ArrangementMeta) -> Self

Converts to this type from the input type.

impl From<(u64, ProtoArrangement)> for ArrangementMeta

fn from(x: (u64, ProtoArrangement)) -> Self

Converts to this type from the input type.

impl PartialEq<ArrangementMeta> for ArrangementMeta

fn eq(&self, other: &ArrangementMeta) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &ArrangementMeta) -> bool

This method tests for !=.

impl Eq for ArrangementMeta

impl StructuralEq for ArrangementMeta

impl StructuralPartialEq for ArrangementMeta