Deprecated: The each() function is deprecated. This message will be suppressed on further calls in /home/zhenxiangba/zhenxiangba.com/public_html/phproxy-improved-master/index.php on line 456
datafusion::execution::physical_plan::BatchIterator - Rust

[−][src]Trait datafusion::execution::physical_plan::BatchIterator

pub trait BatchIterator: Send + Sync {
    fn schema(&self) -> Arc<Schema>;
    fn next(&mut self) -> Result<Option<RecordBatch>>;
}

Iterator over RecordBatch that can be sent between threads

Required methods

`fn schema(&self) -> Arc<Schema>`

Get the schema for the batches returned by this iterator

`fn next(&mut self) -> Result<Option<RecordBatch>>`

Get the next RecordBatch

Loading content...

Implementors

`impl BatchIterator for CsvBatchIterator`[src]

`fn schema(&self) -> Arc<Schema>`[src]

`fn next(&mut self) -> Result<Option<RecordBatch>>`[src]

`impl BatchIterator for MemBatchIterator`[src]

`fn schema(&self) -> Arc<Schema>`[src]

`fn next(&mut self) -> Result<Option<RecordBatch>>`[src]

`impl BatchIterator for RecordBatchIterator`[src]

`fn schema(&self) -> Arc<Schema>`[src]

`fn next(&mut self) -> Result<Option<RecordBatch>>`[src]

Loading content...