Class SourceOperator

java.lang.Object
org.elasticsearch.compute.operator.SourceOperator
All Implemented Interfaces:
Closeable, AutoCloseable, Operator, org.elasticsearch.core.Releasable
Direct Known Subclasses:
EnrichQuerySourceOperator, ExchangeSourceOperator, LocalSourceOperator, LuceneOperator

public abstract class SourceOperator extends Object implements Operator
A source operator - produces output, accepts no input.
  • Constructor Details

    • SourceOperator

      public SourceOperator()
  • Method Details

    • needsInput

      public final boolean needsInput()
      A source operator needs no input - unconditionally returns false.
      Specified by:
      needsInput in interface Operator
      Returns:
      false
    • addInput

      public final void addInput(Page page)
      A source operator does not accept input - unconditionally throws UnsupportedOperationException.
      Specified by:
      addInput in interface Operator
      Parameters:
      page - a page