Package dev.frostlake.executor.operators

Class OperatorPipeline

java.lang.Object

dev.frostlake.executor.operators.OperatorPipeline

public class OperatorPipeline
extends Object

Pipeline of operators for query execution. Operators are executed in sequence, with each operator's output becoming the next operator's input.

Method Summary

Modifier and Type	Method	Description
static OperatorPipelineBuilder	builder()
List<Row>	execute(List<Row> input)	Execute the pipeline on the input rows.
String	getDescription()	Get a description of the entire pipeline.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

execute

public List<Row> execute(List<Row> input)

Execute the pipeline on the input rows.

Parameters:

input - The initial input rows

Returns:

The final output rows after all operators have been applied

getDescription

public String getDescription()

Get a description of the entire pipeline.

Returns:

A human-readable description of all operators in the pipeline

builder

public static OperatorPipelineBuilder builder()