pub trait SessionContextExt {
// Required method
fn read_one_shot(
&self,
data: SendableRecordBatchStream,
) -> Result<DataFrame>;
}
Required Methods§
Sourcefn read_one_shot(&self, data: SendableRecordBatchStream) -> Result<DataFrame>
fn read_one_shot(&self, data: SendableRecordBatchStream) -> Result<DataFrame>
Creates a DataFrame for reading a stream of data
This dataframe may only be queried once, future queries will fail