Module org.elasticsearch.compute
Package org.elasticsearch.compute.lucene
Class LuceneTopNSourceOperator
java.lang.Object
org.elasticsearch.compute.operator.SourceOperator
org.elasticsearch.compute.lucene.LuceneOperator
org.elasticsearch.compute.lucene.LuceneTopNSourceOperator
- All Implemented Interfaces:
Closeable,AutoCloseable,Operator,org.elasticsearch.core.Releasable
Source operator that builds Pages out of the output of a TopFieldCollector (aka TopN)
-
Nested Class Summary
Nested ClassesNested classes/interfaces inherited from class org.elasticsearch.compute.lucene.LuceneOperator
LuceneOperator.StatusNested classes/interfaces inherited from class org.elasticsearch.compute.operator.SourceOperator
SourceOperator.SourceOperatorFactoryNested classes/interfaces inherited from interface org.elasticsearch.compute.operator.Operator
Operator.OperatorFactory -
Field Summary
Fields inherited from class org.elasticsearch.compute.lucene.LuceneOperator
blockFactory, NO_LIMIT, shardContextCountersFields inherited from interface org.elasticsearch.compute.operator.Operator
MIN_TARGET_PAGE_SIZE, NOT_BLOCKED, TARGET_PAGE_SIZE -
Constructor Summary
ConstructorsConstructorDescriptionLuceneTopNSourceOperator(List<? extends ShardContext> contexts, BlockFactory blockFactory, int maxPageSize, List<SortBuilder<?>> sorts, int limit, LuceneSliceQueue sliceQueue, boolean needsScore) -
Method Summary
Modifier and TypeMethodDescriptionprotected voidvoidfinish()notifies the operator that it won't receive any more input pagesbooleanwhether the operator has finished processing all input pages and made the corresponding output pages availableMethods inherited from class org.elasticsearch.compute.lucene.LuceneOperator
additionalClose, close, getOutput, status, toStringMethods inherited from class org.elasticsearch.compute.operator.SourceOperator
addInput, needsInput
-
Constructor Details
-
LuceneTopNSourceOperator
public LuceneTopNSourceOperator(List<? extends ShardContext> contexts, BlockFactory blockFactory, int maxPageSize, List<SortBuilder<?>> sorts, int limit, LuceneSliceQueue sliceQueue, boolean needsScore)
-
-
Method Details
-
isFinished
public boolean isFinished()Description copied from interface:Operatorwhether the operator has finished processing all input pages and made the corresponding output pages available -
finish
public void finish()Description copied from interface:Operatornotifies the operator that it won't receive any more input pages -
getCheckedOutput
- Specified by:
getCheckedOutputin classLuceneOperator- Throws:
IOException
-
describe
- Specified by:
describein classLuceneOperator
-