Struct SystemParamsDiff

pub struct SystemParamsDiff {

    pub barrier_interval_ms: Option<u32>,
    pub checkpoint_frequency: Option<u64>,
    pub sstable_size_mb: Option<u32>,
    pub parallel_compact_size_mb: Option<u32>,
    pub block_size_kb: Option<u32>,
    pub bloom_false_positive: Option<f64>,
    pub state_store: Option<String>,
    pub data_directory: Option<String>,
    pub backup_storage_url: Option<String>,
    pub backup_storage_directory: Option<String>,
    pub max_concurrent_creating_streaming_jobs: Option<u32>,
    pub pause_on_next_bootstrap: Option<bool>,
    pub enable_tracing: Option<bool>,
    pub use_new_object_prefix_strategy: Option<bool>,
    pub license_key: Option<LicenseKey>,
    pub time_travel_retention_ms: Option<u64>,
}

The diff of the system params.

Fields that are changed are set to Some, otherwise None.

Fields

barrier_interval_ms: Option<u32>

The interval of periodic barrier.

checkpoint_frequency: Option<u64>

There will be a checkpoint for every n barriers.

sstable_size_mb: Option<u32>

Target size of the Sstable.

parallel_compact_size_mb: Option<u32>

The size of parallel task for one compact/flush job.

block_size_kb: Option<u32>

Size of each block in bytes in SST.

bloom_false_positive: Option<f64>

False positive probability of bloom filter.

state_store: Option<String>

URL for the state store

data_directory: Option<String>

Remote directory for storing data and metadata objects.

backup_storage_url: Option<String>

Remote storage url for storing snapshots.

backup_storage_directory: Option<String>

Remote directory for storing snapshots.

max_concurrent_creating_streaming_jobs: Option<u32>

Max number of concurrent creating streaming jobs.

pause_on_next_bootstrap: Option<bool>

Whether to pause all data sources on next bootstrap.

enable_tracing: Option<bool>

Whether to enable distributed tracing.

use_new_object_prefix_strategy: Option<bool>

Whether to split object prefix.

license_key: Option<LicenseKey>

The license key to activate enterprise features.

time_travel_retention_ms: Option<u64>

The data retention period for time travel.

Implementations

impl SystemParamsDiff

pub fn diff(prev: impl SystemParamsRead, curr: impl SystemParamsRead) -> Self

Create a diff between the given two system params.

pub fn from_initial(initial: impl SystemParamsRead) -> Self

Create a diff from the given initial system params. All fields will be set to Some.

Trait Implementations

impl Clone for SystemParamsDiff

fn clone(&self) -> SystemParamsDiff

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for SystemParamsDiff

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

Formats the value using the given formatter.

impl Default for SystemParamsDiff

fn default() -> SystemParamsDiff

Returns the “default value” for a type.