Trait polars_lazy::physical_plan::Executor

pub trait Executor: Send + Sync {
    fn execute(
        &mut self, 
        cache: &Arc<Mutex<HashMap<String, DataFrame, RandomState>>>
    ) -> Result<DataFrame>;
}

Executors will evaluate physical expressions and collect them in a DataFrame.

Required methods

fn execute(
    &mut self,
    cache: &Arc<Mutex<HashMap<String, DataFrame, RandomState>>>
) -> Result<DataFrame>

Loading content...

Implementors

impl Executor for CacheExec

fn execute(
    &mut self,
    cache: &Arc<Mutex<HashMap<String, DataFrame, RandomState>>>
) -> Result<DataFrame>

impl Executor for CsvExec

fn execute(
    &mut self,
    cache: &Arc<Mutex<HashMap<String, DataFrame, RandomState>>>
) -> Result<DataFrame>

impl Executor for DataFrameExec

fn execute(
    &mut self,
    _: &Arc<Mutex<HashMap<String, DataFrame, RandomState>>>
) -> Result<DataFrame>

impl Executor for FilterExec

fn execute(
    &mut self,
    cache: &Arc<Mutex<HashMap<String, DataFrame, RandomState>>>
) -> Result<DataFrame>

impl Executor for GroupByExec

fn execute(
    &mut self,
    cache: &Arc<Mutex<HashMap<String, DataFrame, RandomState>>>
) -> Result<DataFrame>

impl Executor for JoinExec

fn execute<'a>(
    &'a mut self,
    cache: &'a Arc<Mutex<HashMap<String, DataFrame, RandomState>>>
) -> Result<DataFrame>

impl Executor for MeltExec

fn execute(
    &mut self,
    cache: &Arc<Mutex<HashMap<String, DataFrame, RandomState>>>
) -> Result<DataFrame>

impl Executor for PartitionGroupByExec

fn execute(
    &mut self,
    cache: &Arc<Mutex<HashMap<String, DataFrame, RandomState>>>
) -> Result<DataFrame>

impl Executor for SliceExec

fn execute(
    &mut self,
    cache: &Arc<Mutex<HashMap<String, DataFrame, RandomState>>>
) -> Result<DataFrame>

impl Executor for StackExec

fn execute(
    &mut self,
    cache: &Arc<Mutex<HashMap<String, DataFrame, RandomState>>>
) -> Result<DataFrame>

impl Executor for StandardExec

fn execute(
    &mut self,
    cache: &Arc<Mutex<HashMap<String, DataFrame, RandomState>>>
) -> Result<DataFrame>

Loading content...