Class LuceneSourceOperator

All Implemented Interfaces:
Closeable, AutoCloseable, Operator, org.elasticsearch.core.Releasable

public class LuceneSourceOperator extends LuceneOperator
Source operator that incrementally runs Lucene searches
  • Constructor Details

    • LuceneSourceOperator

      public LuceneSourceOperator(BlockFactory blockFactory, int maxPageSize, LuceneSliceQueue sliceQueue, int limit, Limiter limiter, boolean needsScore)
  • Method Details

    • 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
    • finish

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

      public Page getCheckedOutput() throws IOException
      Specified by:
      getCheckedOutput in class LuceneOperator
      Throws:
      IOException
    • 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
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Specified by:
      close in interface Operator
      Specified by:
      close in interface org.elasticsearch.core.Releasable
      Overrides:
      close in class LuceneOperator
    • describe

      protected void describe(StringBuilder sb)
      Specified by:
      describe in class LuceneOperator