Method cache

datafusion/core/src/dataframe/mod.rs:2395–2410

Cache DataFrame as a memory table. Default behavior could be changed using a [`crate::execution::session_state::CacheFactory`] configured via [`SessionState`]. ``` # use datafusion::prelude::*; # use datafusion::error::Result; # #[tokio::main] # async fn main() -> Result<()> { let ctx = SessionContext::new(); let df = ctx .read_csv("tests/data/example.csv", CsvReadOptions::new()) .await?; let df

(self)

    /// # }
    /// ```
    pub async fn cache(self) -> Result<DataFrame> {
        if let Some(cache_factory) = self.session_state.cache_factory() {
            let new_plan =
                cache_factory.create(self.plan, self.session_state.as_ref())?;
            Ok(Self::new(*self.session_state, new_plan))
        } else {
            let context = SessionContext::new_with_state((*self.session_state).clone());
            // The schema is consistent with the output
            let plan = self.create_physical_plan().await?;
            let schema = plan.schema();
            let task_ctx = Arc::new(self.task_ctx());
            let partitions = collect_partitioned(plan, task_ctx).await?;
            let mem_table = MemTable::try_new(schema, partitions)?;
            context.read_table(Arc::new(mem_table))
        }
    }

    /// Apply an alias to the DataFrame.
    ///