Method schema

datafusion/physical-plan/src/recursive_query.rs:450–452

Get the schema

(&self)

impl RecordBatchStream for RecursiveQueryStream {
    /// Get the schema
    fn schema(&self) -> SchemaRef {
        Arc::clone(&self.schema)
    }
}

/// Deduplicator based on a hash table.