Struct AdvancedStreamingConfig 

pub struct AdvancedStreamingConfig {
    pub default_windowsize: usize,
    pub adaptive_windowing: bool,
    pub max_buffer_memory: usize,
    pub change_point_detection: bool,
    pub incremental_ml: bool,
    pub distributed_processing: bool,
    pub high_throughput_threshold: f64,
    pub anomaly_detection: bool,
    pub significance_level: f64,
    pub intelligent_compression: bool,
    pub realtime_visualization: bool,
    pub approximate_algorithms: bool,
}

Configuration for advanced streaming analytics

Fields

default_windowsize: usize

Default window size for streaming operations

adaptive_windowing: bool

Enable adaptive windowing based on data characteristics

max_buffer_memory: usize

Maximum memory usage for buffering (bytes)

change_point_detection: bool

Enable real-time change point detection

incremental_ml: bool

Enable incremental machine learning models

distributed_processing: bool

Enable distributed streaming processing

high_throughput_threshold: f64

Data ingestion rate threshold for optimization switching

anomaly_detection: bool

Enable anomaly detection in streams

significance_level: f64

Statistical significance level for change detection

intelligent_compression: bool

Enable intelligent compression for historical data

realtime_visualization: bool

Real-time visualization updates

approximate_algorithms: bool

Enable approximate algorithms for extreme throughput

Trait Implementations

impl Clone for AdvancedStreamingConfig

fn clone(&self) -> AdvancedStreamingConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AdvancedStreamingConfig

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

Formats the value using the given formatter.

impl Default for AdvancedStreamingConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for AdvancedStreamingConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for AdvancedStreamingConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.