Enum PipelineOutput 

pub enum PipelineOutput {
    Rows(Vec<Row>),
    Batch(ColumnarBatch),
    Empty,
}

Polymorphic output from pipeline stages.

Output can be in row or columnar batch format, allowing efficient chaining of pipeline stages with format-appropriate optimizations.

Example

use vibesql_executor::pipeline::PipelineOutput;

// Row-based output
let output = PipelineOutput::from_rows(rows);
let rows = output.into_rows(); // Zero-copy for Rows variant

// Columnar batch output
let output = PipelineOutput::from_batch(batch);
let rows = output.into_rows(); // Materializes batch to rows

Variants

Rows(Vec<Row>)

Row-based output (traditional format)

Batch(ColumnarBatch)

Columnar batch output for SIMD-accelerated pipelines

This variant enables keeping data in columnar format throughout the pipeline for maximum performance.

Empty

Empty output (zero rows)

Implementations

impl PipelineOutput

pub fn from_rows(rows: Vec<Row>) -> Self

Create output from rows.

pub fn from_batch(batch: ColumnarBatch) -> Self

Create output from a columnar batch.

pub fn empty() -> Self

Create empty output.

pub fn into_rows(self) -> Vec<Row>

Convert to rows, consuming the output.

This is the final conversion when returning results to the caller.

Performance

• Rows: Zero-copy move (O(1))
• Batch: Materializes to rows (O(n * m) where m = columns)
• Empty: Returns empty Vec (O(1))

pub fn row_count(&self) -> usize

Get the number of rows in the output.

pub fn is_empty(&self) -> bool

Check if the output is empty.

pub fn as_rows(&self) -> Option<&[Row]>

Try to get rows as a slice (only works for Rows variant).

Returns None for Batch and Empty variants.

pub fn as_batch(&self) -> Option<&ColumnarBatch>

Try to get the columnar batch (only works for Batch variant).

Returns None for Rows and Empty variants.

pub fn into_batch(self) -> Option<ColumnarBatch>

Consume and return the columnar batch if this is a Batch variant.

Returns None for other variants.

pub fn is_batch(&self) -> bool

Check if this output is in columnar batch format.

pub fn is_rows(&self) -> bool

Check if this output is in row format.

pub fn into_input(self) -> PipelineInput<'static>

Convert to PipelineInput for chaining pipeline stages.

This enables fluent chaining: filter().project().aggregate() Preserves the data format (rows stay rows, batches stay batches).

Trait Implementations

impl Debug for PipelineOutput

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for PipelineOutput

fn default() -> PipelineOutput

Returns the “default value” for a type.