Package dev.frostlake.executor.operators

Interface Operator

All Known Implementing Classes:
AsofJoinOperator, GroupByOperator, HavingOperator, JoinOperator, LimitOperator, ProjectOperator, QualifyOperator, TableFunctionOperator, WhereOperator
public interface Operator
Base interface for query execution operators. Operators form a pipeline where each operator processes rows and passes them to the next.

  • Method Summary

    Modifier and Type
    Method
    Description
    List<Row>
    execute(List<Row> input, OperatorContext context)
    Execute this operator on the input rows.
    String
    getDescription()
    Get a description of this operator for debugging/logging.

  • Method Details

    • execute

      List<Row> execute(List<Row> input, OperatorContext context)
      Execute this operator on the input rows.
      Parameters:
      input - The input rows from the previous operator
      context - The execution context containing table metadata and other information
      Returns:
      The output rows after applying this operator

    • getDescription

      String getDescription()
      Get a description of this operator for debugging/logging.
      Returns:
      A human-readable description of the operator