pandrs 0.3.1

A high-performance DataFrame library for Rust, providing pandas-like API with advanced features including SIMD optimization, parallel processing, and distributed computing capabilities
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42

//! Advanced distributed processing tests for PandRS
//!
//! Note: These tests require modules that are currently under development.
//! Full test coverage will be available in a future release.

#[cfg(feature = "distributed")]
mod tests {
    use pandrs::distributed::{DistributedConfig, DistributedContext};
    use pandrs::error::Result;

    #[test]
    #[allow(clippy::result_large_err)]
    fn test_distributed_context_basic() -> Result<()> {
        // Basic context creation test
        let config = DistributedConfig::new()
            .with_executor("datafusion")
            .with_concurrency(2);

        let _context = DistributedContext::new(config)?;
        Ok(())
    }

    #[test]
    fn test_distributed_config() {
        // Test configuration options
        let config = DistributedConfig::new()
            .with_executor("datafusion")
            .with_concurrency(4)
            .with_optimization(true);

        assert_eq!(config.concurrency(), 4);
    }
}

#[cfg(not(feature = "distributed"))]
mod tests {
    #[test]
    fn test_distributed_feature_disabled() {
        // This test runs when distributed feature is disabled
        assert!(true, "Distributed feature is disabled");
    }
}