dbsp 0.287.0

Continuous streaming analytics engine
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use anyhow::Result;
use csv::Reader;
use serde::Deserialize;

#[allow(dead_code)]
#[derive(Debug, Deserialize)]
struct Record {
    location: String,
    date: i32,
    daily_vaccinations: Option<u64>,
}

fn main() -> Result<()> {
    let path = format!(
        "{}/examples/tutorial/vaccinations.csv",
        env!("CARGO_MANIFEST_DIR")
    );
    for result in Reader::from_path(path)?.deserialize() {
        let record: Record = result?;
        println!("{:?}", record);
    }
    Ok(())
}