Package dev.frostlake.executor.streaming

package dev.frostlake.executor.streaming
  • Class
    Description
    FilterRowStream
    Yields only the rows from its source that satisfy a predicate (the streaming WHERE).
    LimitRowStream
    Skips offset rows then yields at most limit rows, returning null — and not pulling any further from its source — once the limit is reached.
    ListRowStream
    Leaf source that streams rows from an existing list lazily (by index, without copying it).
    ProjectRowStream
    Applies a per-row transform (the streaming projection) to its source.
    RowMapper
    Per-row transform (projection) for ProjectRowStream.
    RowPredicate
    Row filter predicate for FilterRowStream.
    RowStream
    Pull-based (volcano-model) stream of rows: each RowStream.next() call produces one row on demand and returns null when exhausted, so a downstream operator (e.g.