MCPcopy Create free account
hub / github.com/apache/datafusion / select_into

Method select_into

datafusion/sql/src/query.rs:362–381  ·  view source on GitHub ↗

Wrap the logical plan in a `SelectInto`

(
        &self,
        plan: LogicalPlan,
        select_into: Option<SelectInto>,
    )

Source from the content-addressed store, hash-verified

360
361 /// Wrap the logical plan in a `SelectInto`
362 fn select_into(
363 &self,
364 plan: LogicalPlan,
365 select_into: Option<SelectInto>,
366 ) -> Result<LogicalPlan> {
367 match select_into {
368 Some(into) => Ok(LogicalPlan::Ddl(DdlStatement::CreateMemoryTable(
369 CreateMemoryTable {
370 name: self.object_name_to_table_reference(into.name)?,
371 constraints: Constraints::default(),
372 input: Arc::new(plan),
373 if_not_exists: false,
374 or_replace: false,
375 temporary: false,
376 column_defaults: vec![],
377 },
378 ))),
379 _ => Ok(plan),
380 }
381 }
382}
383
384/// Returns the order by expressions from the query.

Callers 1

query_to_planMethod · 0.80

Calls 3

CreateMemoryTableClass · 0.85
newFunction · 0.85

Tested by

no test coverage detected