Method create_view

datafusion/core/src/execution/context/mod.rs:939–972

(&self, cmd: CreateView)

    }

    async fn create_view(&self, cmd: CreateView) -> Result<DataFrame> {
        let CreateView {
            name,
            input,
            or_replace,
            definition,
            temporary,
        } = cmd;

        let view = self.table(name.clone()).await;

        if temporary {
            return not_impl_err!("Temporary views not supported");
        }

        match (or_replace, view) {
            (true, Ok(_)) => {
                let input = Self::apply_type_coercion(Arc::unwrap_or_clone(input))?;
                Self::ensure_unique_column_names(input.schema())?;
                self.deregister_table(name.clone())?;
                let table = Arc::new(ViewTable::new(input, definition));
                self.register_table(name, table)?;
                self.return_empty_dataframe()
            }
            (_, Err(_)) => {
                let input = Self::apply_type_coercion(Arc::unwrap_or_clone(input))?;
                Self::ensure_unique_column_names(input.schema())?;
                let table = Arc::new(ViewTable::new(input, definition));
                self.register_table(name, table)?;
                self.return_empty_dataframe()
            }
            (false, Ok(_)) => exec_err!("Table '{name}' already exists"),
        }
    }

    fn ensure_unique_column_names(schema: &DFSchema) -> Result<()> {
        // DFSchema name checks allow duplicate unqualified names as long as their