Method from_columns

datafusion/core/src/dataframe/mod.rs:2570–2586

Helper for creating DataFrame. # Example ``` use arrow::array::{ArrayRef, Int32Array, StringArray}; use datafusion::prelude::DataFrame; use std::sync::Arc; let id: ArrayRef = Arc::new(Int32Array::from(vec![1, 2, 3])); let name: ArrayRef = Arc::new(StringArray::from(vec!["foo", "bar", "baz"])); let df = DataFrame::from_columns(vec![("id", id), ("name", name)]).unwrap(); // +----+------+, // | id |

(columns: Vec<(&str, ArrayRef)>)

    /// // +----+------+,
    /// ```
    pub fn from_columns(columns: Vec<(&str, ArrayRef)>) -> Result<Self> {
        let fields = columns
            .iter()
            .map(|(name, array)| Field::new(*name, array.data_type().clone(), true))
            .collect::<Vec<_>>();

        let arrays = columns
            .into_iter()
            .map(|(_, array)| array)
            .collect::<Vec<_>>();

        let schema = Arc::new(Schema::new(fields));
        let batch = RecordBatch::try_new(schema, arrays)?;
        let ctx = SessionContext::new();
        let df = ctx.read_batch(batch)?;
        Ok(df)
    }
}

/// Macro for creating DataFrame.