Module state_table 

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

StateTableBuilder

StateTableInner

StateTableInner is the interface accessing relational data in KV(StateStore) with row-based encoding.

StateTablePostCommit

A callback struct returned from StateTableInner::commit.

StateTableRowStore 🔒

Extract the logic of StateTableRowStore from StateTable, which serves a similar functionality as a BTreeMap<TableKey<Bytes>, OwnedRow>, and provides method to read (get and iter) over serialized key (or key range) and returns OwnedRow, and write (insert, delete, update) on (TableKey<Bytes>, OwnedRow).

Enums

StateTableOpConsistencyLevel

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

FromVnodeBytes

KeyedRowStream

PkRowStream

RowStream

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

ReplicatedStateTable

ReplicatedStateTable is meant to replicate upstream shared buffer. Used for ArrangementBackfill executor.

StateTable

StateTable will use BasicSerde as default

WatermarkCacheParameterizedStateTable

WatermarkCacheStateTable

WatermarkCacheStateTable caches the watermark column. It will reduce state cleaning overhead.