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.

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

• KeyedRowStream

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.