Type Alias IterNode

type IterNode = GenericNode<BoxedRecordBatchIterator>;

Aliased Type

struct IterNode {
    node_index: usize,
    iter: Box<dyn Iterator<Item = Result<RecordBatch, Error>> + Send>,
    cursor: Option<RowCursor>,
}

Fields

node_index: usize

Index of the node.

iter: Box<dyn Iterator<Item = Result<RecordBatch, Error>> + Send>

Iterator of this Node.

cursor: Option<RowCursor>

Current batch to be read. The node should ensure the batch is not empty (The cursor is not finished).

None means the iter has reached EOF.