pandrs 0.1.0-beta.2

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
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124

use pandrs::dataframe::{DataFrame, DataFrameWindowExt};
use pandrs::error::Result;
use pandrs::series::Series;

#[allow(clippy::result_large_err)]
#[allow(clippy::result_large_err)]
fn main() -> Result<()> {
    println!("=== Example of DataFrame Window Operations ===\n");

    // Create sample data
    let df = create_sample_dataframe()?;

    // Display the contents of the DataFrame
    println!("Original DataFrame:");
    println!("{df:?}\n");

    // 1. Example of rolling mean
    println!("1. Example of rolling mean");
    let df_rolling = df.rolling(3, "Price", "mean", None)?;
    println!("{df_rolling:?}\n");

    // 2. Example of rolling sum
    println!("2. Example of rolling sum");
    let df_sum = df.rolling(3, "Quantity", "sum", Some("Quantity_RollingSum_3"))?;
    println!("{df_sum:?}\n");

    // 3. Example of rolling standard deviation
    println!("3. Example of rolling standard deviation");
    let df_std = df.rolling(3, "Price", "std", None)?;
    println!("{df_std:?}\n");

    // 4. Example of rolling minimum
    println!("4. Example of rolling minimum");
    let df_min = df.rolling(3, "Price", "min", None)?;
    println!("{df_min:?}\n");

    // 5. Example of rolling maximum
    println!("5. Example of rolling maximum");
    let df_max = df.rolling(3, "Price", "max", None)?;
    println!("{df_max:?}\n");

    // 6. Example of expanding mean
    println!("6. Example of expanding mean");
    let df_expanding = df.expanding(2, "Price", "mean", None)?;
    println!("{df_expanding:?}\n");

    // 7. Example of Exponential Weighted Moving Average (EWM)
    println!("7. Example of Exponential Weighted Moving Average (EWM)");

    // When span is specified (span = 3)
    let df_ewm_span = df.ewm("Price", "mean", Some(3), None, Some("Price_ewm_span3"))?;
    println!("7.1 When span=3 is specified:");
    println!("{df_ewm_span:?}\n");

    // When alpha is specified (alpha = 0.5)
    let df_ewm_alpha = df.ewm("Price", "mean", None, Some(0.5), Some("Price_ewm_alpha0.5"))?;
    println!("7.2 When alpha=0.5 is specified:");
    println!("{df_ewm_alpha:?}\n");

    // 8. Example of applying multiple operations at once
    println!("8. Example of combining multiple operations:");

    // Apply multiple operations in sequence
    let mut result_df = df.clone();

    // Add rolling mean
    result_df = result_df.rolling(3, "Price", "mean", None)?;

    // Add expanding mean
    result_df = result_df.expanding(2, "Price", "mean", None)?;

    // Add Exponential Weighted Moving Average
    result_df = result_df.ewm("Price", "mean", Some(3), None, None)?;

    println!("{result_df:?}\n");

    println!("=== DataFrame Window Operations Example Complete ===");
    Ok(())
}

// Helper function to create a sample DataFrame
#[allow(clippy::result_large_err)]
#[allow(clippy::result_large_err)]
fn create_sample_dataframe() -> Result<DataFrame> {
    let mut df = DataFrame::new();

    // Add date column
    let dates = vec![
        "2023-01-01",
        "2023-01-02",
        "2023-01-03",
        "2023-01-04",
        "2023-01-05",
        "2023-01-06",
        "2023-01-07",
        "2023-01-08",
        "2023-01-09",
        "2023-01-10",
    ];
    let date_series = Series::new(dates, Some("Date".to_string()))?;
    df.add_column("Date".to_string(), date_series)?;

    // Add product column
    let products = vec![
        "ProductA", "ProductB", "ProductA", "ProductC", "ProductB", "ProductA", "ProductC",
        "ProductA", "ProductB", "ProductC",
    ];
    let product_series = Series::new(products, Some("Product".to_string()))?;
    df.add_column("Product".to_string(), product_series)?;

    // Add price column
    let prices = vec![
        "100", "150", "110", "200", "160", "120", "210", "115", "165", "220",
    ];
    let price_series = Series::new(prices, Some("Price".to_string()))?;
    df.add_column("Price".to_string(), price_series)?;

    // Add quantity column
    let quantities = vec!["5", "3", "6", "2", "4", "7", "3", "8", "5", "4"];
    let quantity_series = Series::new(quantities, Some("Quantity".to_string()))?;
    df.add_column("Quantity".to_string(), quantity_series)?;

    Ok(df)
}