polars-stream 0.53.0

Private crate for the streaming execution engine for the Polars DataFrame library
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use polars_error::{PolarsError, polars_err};

pub fn missing_column_err(missing_column_name: &str) -> PolarsError {
    polars_err!(
        ColumnNotFound:
        "did not find column {}, consider passing `missing_columns='insert'`",
        missing_column_name,
    )
}

pub fn extra_column_err(extra_column_name: &str, file_path: &str) -> PolarsError {
    polars_err!(
        SchemaMismatch:
        "extra column in file outside of expected schema: {}, \
        hint: specify this column in the schema, or pass \
        extra_columns='ignore' in scan options. File containing extra column: \
        '{}'.",
        extra_column_name, file_path,
    )
}