risingwave_stream::common::table

Module state_table_cache

source

Structs§

Type Aliases§

  • WatermarkCacheKey 🔒
    The watermark cache key is just an OwnedRow wrapped in DefaultOrdered. This is because we want to use the DefaultOrdered implementation of Ord. The assumption is that the watermark column is the first column in the row. So it should automatically be ordered by the watermark column. We disregard the ordering of the remaining PK datums.