Class EnrichQuerySourceOperator

java.lang.Object
org.elasticsearch.compute.operator.SourceOperator
org.elasticsearch.compute.operator.lookup.EnrichQuerySourceOperator
All Implemented Interfaces:
Closeable, AutoCloseable, Operator, org.elasticsearch.core.Releasable

public final class EnrichQuerySourceOperator extends SourceOperator
Lookup document IDs for the input queries. This operator will emit Pages consisting of a DocVector and IntBlock of positions for each query of the input queries. The position block will be used as keys to combine the extracted values by MergePositionsOperator.
  • Field Details

  • Constructor Details

  • Method Details

    • finish

      public void finish()
      Description copied from interface: Operator
      notifies the operator that it won't receive any more input pages
    • isFinished

      public boolean isFinished()
      Description copied from interface: Operator
      whether the operator has finished processing all input pages and made the corresponding output pages available
    • getOutput

      public Page getOutput()
      Description copied from interface: Operator
      returns non-null if output page available. Only called when isFinished() == false
    • close

      public void close()
      Description copied from interface: Operator
      notifies the operator that it won't be used anymore (i.e. none of the other methods called), and its resources can be cleaned up