Package dev.frostlake.executor.streaming

Interface RowStream

All Known Implementing Classes:
FilterRowStream, LimitRowStream, ListRowStream, ProjectRowStream
public interface RowStream
Pull-based (volcano-model) stream of rows: each next() call produces one row on demand and returns null when exhausted, so a downstream operator (e.g. LIMIT) can stop pulling without the upstream having to materialize its full output.

This is the streaming counterpart to the materializing Operator pipeline (which passes whole List<Row>s between stages). It is the foundation for lazy execution / LIMIT short-circuit; production query execution is not yet routed through it — that wiring is a deliberate follow-up step.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
    Release any resources held by this stream and its sources.
    Row
    next()
    The next row, or null when the stream is exhausted.

  • Method Details

    • next

      Row next()
      The next row, or null when the stream is exhausted.

    • close

      void close()
      Release any resources held by this stream and its sources.