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

mod cache;
mod executor;
mod ext_context;
mod filter;
mod group_by;
mod group_by_dynamic;
mod group_by_partitioned;
pub(super) mod group_by_rolling;
mod hconcat;
mod join;
mod projection;
mod projection_simple;
mod projection_utils;
#[cfg(feature = "python")]
mod python_scan;
mod scan;
mod slice;
mod sort;
mod stack;
mod udf;
mod union;
mod unique;

use std::borrow::Cow;

pub use executor::*;
use polars_core::POOL;
use polars_plan::global::FETCH_ROWS;
use polars_plan::utils::*;
use projection_utils::*;
use rayon::prelude::*;

pub(super) use self::cache::*;
pub(super) use self::ext_context::*;
pub(super) use self::filter::*;
pub(super) use self::group_by::*;
#[cfg(feature = "dynamic_group_by")]
pub(super) use self::group_by_dynamic::*;
pub(super) use self::group_by_partitioned::*;
#[cfg(feature = "dynamic_group_by")]
pub(super) use self::group_by_rolling::GroupByRollingExec;
pub(super) use self::hconcat::*;
pub(super) use self::join::*;
pub(super) use self::projection::*;
pub(super) use self::projection_simple::*;
#[cfg(feature = "python")]
pub(super) use self::python_scan::*;
pub(super) use self::scan::*;
pub(super) use self::slice::*;
pub(super) use self::sort::*;
pub(super) use self::stack::*;
pub(super) use self::udf::*;
pub(super) use self::union::*;
pub(super) use self::unique::*;
use super::*;