Book a Demo!
CoCalc Logo Icon
StoreFeaturesDocsShareSupportNewsAboutPoliciesSign UpSign In
pola-rs
GitHub Repository: pola-rs/polars
 Path: blob/main/crates/polars-mem-engine/src/executors/mod.rs
8422 views
1
mod cache;

2
mod executor;

3
mod ext_context;

4
mod filter;

5
mod group_by;

6
mod group_by_dynamic;

7
pub(super) mod group_by_rolling;

8
mod group_by_streaming;

9
mod hconcat;

10
mod join;

11
#[cfg(feature = "merge_sorted")]

12
mod merge_sorted;

13
mod projection;

14
mod projection_simple;

15
mod projection_utils;

16
mod scan;

17
mod slice;

18
mod sort;

19
mod stack;

20
mod udf;

21
mod union;

22
mod unique;

23


24
use std::borrow::Cow;

25


26
pub use executor::*;

27
use polars_core::POOL;

28
use polars_plan::utils::*;

29
use projection_utils::*;

30
use rayon::prelude::*;

31


32
pub(super) use self::cache::*;

33
pub(super) use self::ext_context::*;

34
pub(super) use self::filter::*;

35
pub(super) use self::group_by::*;

36
#[cfg(feature = "dynamic_group_by")]

37
pub(super) use self::group_by_dynamic::*;

38
#[cfg(feature = "dynamic_group_by")]

39
pub(super) use self::group_by_rolling::GroupByRollingExec;

40
pub(super) use self::group_by_streaming::*;

41
pub(super) use self::hconcat::*;

42
pub(super) use self::join::*;

43
#[cfg(feature = "merge_sorted")]

44
pub(super) use self::merge_sorted::*;

45
pub(super) use self::projection::*;

46
pub(super) use self::projection_simple::*;

47
pub(super) use self::scan::*;

48
pub(super) use self::slice::*;

49
pub(super) use self::sort::*;

50
pub(super) use self::stack::*;

51
pub(super) use self::udf::*;

52
pub(super) use self::union::*;

53
pub(super) use self::unique::*;

54
use crate::prelude::*;

55


56