Module state_table

Macros

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

StateTableInner

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

StateTablePostCommit

A callback struct returned from StateTableInner::commit.

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.

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.

Trait Aliases

KeyedRowStream

PkRowStream

RowStream