Struct Configuration 

pub struct Configuration {
    pub config_path: ConfigPath,
    pub frontend_nodes: usize,
    pub compute_nodes: usize,
    pub meta_nodes: usize,
    pub compactor_nodes: usize,
    pub compute_node_cores: usize,
    pub per_session_queries: Arc<Vec<String>>,
    pub compute_resource_groups: HashMap<usize, String>,
}

RisingWave cluster configuration.

Fields

config_path: ConfigPath

The path to configuration file.

Empty string means using the default config.

frontend_nodes: usize

The number of frontend nodes.

compute_nodes: usize

The number of compute nodes.

meta_nodes: usize

The number of meta nodes.

compactor_nodes: usize

The number of compactor nodes.

compute_node_cores: usize

The number of CPU cores for each compute node.

This determines worker_node_parallelism.

per_session_queries: Arc<Vec<String>>

Queries to run per session.

compute_resource_groups: HashMap<usize, String>

Resource groups for compute nodes.

Implementations

impl Configuration

pub fn for_scale() -> Self

Returns the configuration for scale test.

pub fn for_scale_no_shuffle() -> Self

Provides a configuration for scale test which ensures that the arrangement backfill is disabled, so table scan will use no_shuffle.

pub fn for_scale_shared_source() -> Self

pub fn for_auto_parallelism( max_heartbeat_interval_secs: u64, enable_auto_parallelism: bool, ) -> Self

pub fn for_default_parallelism(default_parallelism: usize) -> Self

pub fn for_backfill() -> Self

Returns the config for backfill test.

pub fn for_arrangement_backfill() -> Self

pub fn for_background_ddl() -> Self

pub fn enable_arrangement_backfill() -> Self

pub fn total_streaming_cores(&self) -> u32

Returns the total number of cores for streaming compute nodes.

Trait Implementations

impl Clone for Configuration

fn clone(&self) -> Configuration

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Configuration

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

Formats the value using the given formatter.

impl Default for Configuration

fn default() -> Self

Returns the “default value” for a type.