java.lang.Object
org.elasticsearch.compute.operator.SinkOperator
All Implemented Interfaces:
Closeable, AutoCloseable, Operator, org.elasticsearch.core.Releasable
Direct Known Subclasses:
ExchangeSinkOperator, OutputOperator, PageConsumerOperator

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

    • SinkOperator

      public SinkOperator()
  • Method Details

    • getOutput

      public final Page getOutput()
      A sink operator produces no output - unconditionally throws UnsupportedOperationException
      Specified by:
      getOutput in interface Operator
    • doAddInput

      protected abstract void doAddInput(Page page)
    • addInput

      public final void addInput(Page page)
      Description copied from interface: Operator
      adds an input page to the operator. only called when needsInput() == true and isFinished() == false
      Specified by:
      addInput in interface Operator