Creates a [`DataFrame`] for a [`TableProvider`] such as a [`ListingTable`] or a custom user defined provider.
(&self, provider: Arc<dyn TableProvider>)
| 1761 | /// Creates a [`DataFrame`] for a [`TableProvider`] such as a |
| 1762 | /// [`ListingTable`] or a custom user defined provider. |
| 1763 | pub fn read_table(&self, provider: Arc<dyn TableProvider>) -> Result<DataFrame> { |
| 1764 | Ok(DataFrame::new( |
| 1765 | self.state(), |
| 1766 | LogicalPlanBuilder::scan(UNNAMED_TABLE, provider_as_source(provider), None)? |
| 1767 | .build()?, |
| 1768 | )) |
| 1769 | } |
| 1770 | |
| 1771 | /// Creates a [`DataFrame`] for reading a [`RecordBatch`] |
| 1772 | pub fn read_batch(&self, batch: RecordBatch) -> Result<DataFrame> { |