Struct StreamingConfig 

pub struct StreamingConfig {
    pub in_flight_barrier_nums: usize,
    pub snapshot_backfill_finish_max_lagged_barriers: usize,
    pub snapshot_backfill_barrier_amplification_factor: usize,
    pub actor_runtime_worker_threads_num: Option<usize>,
    pub async_stack_trace: AsyncStackTraceOption,
    pub developer: StreamingDeveloperConfig,
    pub unique_user_stream_errors: usize,
    pub unsafe_disable_strict_consistency: bool,
    pub unrecognized: Unrecognized<Self>,
}

The section [streaming] in risingwave.toml.

Fields

in_flight_barrier_nums: usize

The maximum number of pending barriers in each partial graph. Pending barriers include in-flight, collected but not committed, and currently completing barriers.

snapshot_backfill_finish_max_lagged_barriers: usize

The maximum number of lagged barriers allowed when merging a snapshot backfill job into the database graph.

snapshot_backfill_barrier_amplification_factor: usize

The multiplier applied to in_flight_barrier_nums when limiting pending barriers in a snapshot backfill partial graph. A value of 0 is treated as 1.

actor_runtime_worker_threads_num: Option<usize>

The thread number of the streaming actor runtime in the compute node. The default value is decided by tokio.

async_stack_trace: AsyncStackTraceOption

Enable async stack tracing through await-tree for risectl.

developer: StreamingDeveloperConfig

unique_user_stream_errors: usize

Max unique user stream errors per actor

unsafe_disable_strict_consistency: bool

Disable strict stream consistency checks.

unrecognized: Unrecognized<Self>

Implementations

impl StreamingConfig

pub fn config_docs( name: String, docs: &mut BTreeMap<String, Vec<(String, String)>>, )

impl StreamingConfig

pub fn unrecognized_keys(&self) -> impl Iterator<Item = String>

Returns the dot-separated keys of all unrecognized fields, including those in developer section.

Trait Implementations

impl Clone for StreamingConfig

fn clone(&self) -> StreamingConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StreamingConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for StreamingConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for StreamingConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for StreamingConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.