Macros§
- dispatch_
value_ 🔒indices - insane_
mode_ 🔒discard_ point - This macro is used to mark a point where we want to randomly discard the operation and early return, only in insane mode.
Structs§
- State
Table Builder - State
Table Inner StateTableInneris the interface accessing relational data in KV(StateStore) with row-based encoding.- State
Table Post Commit - A callback struct returned from
StateTableInner::commit. - State
Table 🔒RowStore - Extract the logic of
StateTableRowStorefromStateTable, which serves a similar functionality as aBTreeMap<TableKey<Bytes>, OwnedRow>, and provides method to read (getanditer) over serialized key (or key range) and returnsOwnedRow, and write (insert,delete,update) on(TableKey<Bytes>, OwnedRow).
Enums§
Constants§
- WATERMARK_
CACHE_ 🔒ENTRIES - Mostly watermark operators will have inserts (append-only). So this number should not need to be very large. But we may want to improve this choice in the future.
Traits§
Functions§
- consistent_
old_ 🔒value_ op - deserialize_
keyed_ 🔒row_ stream - end_
range_ 🔒to_ memcomparable - fill_
non_ 🔒output_ indices - prefix_
and_ 🔒sub_ range_ to_ memcomparable - prefix_
range_ to_ memcomparable - start_
range_ 🔒to_ memcomparable
Type Aliases§
- Replicated
State Table ReplicatedStateTableis meant to replicate upstream shared buffer. Used forArrangementBackfillexecutor.- State
Table StateTablewill useBasicSerdeas default- Watermark
Cache Parameterized State Table - Watermark
Cache State Table WatermarkCacheStateTablecaches the watermark column. It will reduce state cleaning overhead.