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
6940 views
1
mod cache;

2
mod executor;

3
mod ext_context;

4
mod filter;

5
mod group_by;

6
mod group_by_dynamic;

7
mod group_by_partitioned;

8
pub(super) mod group_by_rolling;

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 sink;

18
mod slice;

19
mod sort;

20
mod stack;

21
mod udf;

22
mod union;

23
mod unique;

24


25
use std::borrow::Cow;

26


27
pub use executor::*;

28
use polars_core::POOL;

29
use polars_plan::utils::*;

30
use projection_utils::*;

31
use rayon::prelude::*;

32


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

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

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

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

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

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

39
pub(super) use self::group_by_partitioned::*;

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

56
use crate::prelude::*;

57


58