polars_stream/
lib.rs

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
mod async_executor;
mod async_primitives;
mod skeleton;

pub use skeleton::run_query;

mod execute;
pub(crate) mod expression;
mod graph;
mod morsel;
mod nodes;
mod physical_plan;
mod pipe;
mod utils;

// TODO: experiment with these, and make them configurable through environment variables.
const DEFAULT_LINEARIZER_BUFFER_SIZE: usize = 4;
const DEFAULT_DISTRIBUTOR_BUFFER_SIZE: usize = 4;
const DEFAULT_ZIP_HEAD_BUFFER_SIZE: usize = 4;

const GROUP_BY_MIN_ROWS_PER_PARTITION: usize = 128;