Struct SessionInitConfig 

pub struct SessionInitConfig {
    pub streaming_parallelism: Option<String>,
    pub streaming_parallelism_for_backfill: Option<String>,
    pub streaming_parallelism_for_table: Option<String>,
    pub streaming_parallelism_for_sink: Option<String>,
    pub streaming_parallelism_for_index: Option<String>,
    pub streaming_parallelism_for_source: Option<String>,
    pub streaming_parallelism_for_materialized_view: Option<String>,
}

The section [session_init] in risingwave.toml, generated from the SESSION_INIT-flagged fields of [SessionConfig].

It seeds the corresponding persisted session parameters into the meta store during cluster bootstrap only. The precedence is:

1. Persisted value in the meta store (session_parameter)
2. Explicit value in [session_init]
3. Built-in SessionConfig::default()

Editing [session_init] after a cluster has been bootstrapped does not change the effective value of an already-persisted parameter. See the RFC for details.

Fields

streaming_parallelism: Option<String>

The execution parallelism for streaming queries, including tables, materialized views, indexes, and sinks. Defaults to default, which preserves the legacy adaptive scheduling behavior during effective resolution.

streaming_parallelism_for_backfill: Option<String>

Specific parallelism for backfill. Only default and a fixed positive integer are supported here. Adaptive backfill strategies are deferred to a later change.

streaming_parallelism_for_table: Option<String>

Specific parallelism for table. Defaults to default, which preserves the legacy bounded adaptive behavior only when the global parallelism itself remains default. Otherwise it follows the explicit global parallelism.

streaming_parallelism_for_sink: Option<String>

Specific parallelism for sink. By default, it will fall back to STREAMING_PARALLELISM.

streaming_parallelism_for_index: Option<String>

Specific parallelism for index. By default, it will fall back to STREAMING_PARALLELISM.

streaming_parallelism_for_source: Option<String>

Specific parallelism for source. Defaults to default, which preserves the legacy bounded adaptive behavior only when the global parallelism itself remains default. Otherwise it follows the explicit global parallelism.

streaming_parallelism_for_materialized_view: Option<String>

Specific parallelism for materialized view. By default, it will fall back to STREAMING_PARALLELISM.

Implementations

impl SessionInitConfig

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

impl SessionInitConfig

pub fn entries(&self) -> Vec<(&'static str, &str)>

Returns the explicitly-configured (session parameter entry name, value) pairs. Parameters omitted from [session_init] are not included.

Trait Implementations

impl Clone for SessionInitConfig

fn clone(&self) -> SessionInitConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SessionInitConfig

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

Formats the value using the given formatter.

impl Default for SessionInitConfig

fn default() -> SessionInitConfig

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for SessionInitConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for SessionInitConfig

fn eq(&self, other: &SessionInitConfig) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for SessionInitConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for SessionInitConfig