dialect_polars/dialect_polars.rs
1use polars::prelude::*;
2
3fn main() -> anyhow::Result<()> {
4 tracing_subscriber::fmt::init();
5 let df = CsvReadOptions::default()
6 .with_has_header(true)
7 .try_into_reader_with_file_path(Some("owid-covid-latest.csv".into()))?
8 .finish()?;
9
10 let filtered = df.filter(&df["new_deaths"].gt(200)?)?;
11 println!("{:?}", filtered.select(["location", "total_cases", "new_cases", "total_deaths", "new_deaths"]));
12 Ok(())
13}