Type Alias StreamNode

type StreamNode = GenericNode<BoxedRecordBatchStream>;

Aliased Type

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

Fields

node_index: usize

Index of the node.

iter: Pin<Box<dyn Stream<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.