risingwave_
stream
2.4.0-alpha
In risingwave_
stream::
common::
table::
state_
table
Macros
insane_mode_discard_point
Structs
StateTableInner
StateTablePostCommit
Enums
StateTableOpConsistencyLevel
Constants
WATERMARK_CACHE_ENTRIES
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
StateTable
WatermarkCacheParameterizedStateTable
WatermarkCacheStateTable
Trait Aliases
KeyedRowStream
PkRowStream
RowStream
risingwave_stream
::
common
::
table
::
state_table
Trait Alias
KeyedRowStream
Copy item path
Settings
Help
Summary
Source
trait KeyedRowStream<'a> =
Stream
<Item =
StreamExecutorResult
<KeyedRow<Bytes>>> + 'a;