Module org.elasticsearch.compute

Package org.elasticsearch.compute.lucene.query

Class LuceneTopNSourceOperator

java.lang.Object

org.elasticsearch.compute.operator.SourceOperator

org.elasticsearch.compute.lucene.query.LuceneOperator

org.elasticsearch.compute.lucene.query.LuceneTopNSourceOperator

All Implemented Interfaces:

Closeable, AutoCloseable, Operator, org.elasticsearch.core.Releasable

public final class LuceneTopNSourceOperator
extends LuceneOperator

Source operator that builds Pages out of the output of a TopFieldCollector (aka TopN).

Makes Pages of the shape (docBlock) or (docBlock, score). Lucene loads the sort keys, but we don't read them from lucene. Yet. We should.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	LuceneTopNSourceOperator.Factory

Nested classes/interfaces inherited from class org.elasticsearch.compute.lucene.query.LuceneOperator

LuceneOperator.Status

Nested classes/interfaces inherited from class org.elasticsearch.compute.operator.SourceOperator

SourceOperator.ShardLoad, SourceOperator.SourceOperatorFactory

Nested classes/interfaces inherited from interface org.elasticsearch.compute.operator.Operator

Operator.OperatorFactory

Field Summary

Fields inherited from class org.elasticsearch.compute.lucene.query.LuceneOperator

blockFactory, currentSlice, NO_LIMIT, refCounteds, SMALL_INDEX_BOUNDARY

Fields inherited from interface org.elasticsearch.compute.operator.Operator

MIN_TARGET_PAGE_SIZE, NOT_BLOCKED, TARGET_PAGE_SIZE

Constructor Summary

Constructors

Constructor	Description
LuceneTopNSourceOperator(IndexedByShardId<? extends ShardContext> contexts, DriverContext driverContext, int maxPageSize, List<SortBuilder<?>> sorts, long estimatedPerRowSortSize, int limit, LuceneSliceQueue sliceQueue, boolean needsScore, org.elasticsearch.compute.lucene.query.LuceneTopNSourceOperator.PerShardCollectorProvider perShardCollectorProvider)

Method Summary

Modifier and Type	Method	Description
protected void	additionalClose()
protected void	describe(StringBuilder sb)
void	finish()	notifies the operator that it won't receive any more input pages
Page	getCheckedOutput()
boolean	isFinished()	whether the operator has finished processing all input pages and made the corresponding output pages available

Methods inherited from class org.elasticsearch.compute.lucene.query.LuceneOperator

close, getOutput, getSliceQueue, isBlocked, shardLoadDelta, status, toString

Methods inherited from class org.elasticsearch.compute.operator.SourceOperator

addInput, canProduceMoreDataWithoutExtraInput, needsInput

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

LuceneTopNSourceOperator

public LuceneTopNSourceOperator(IndexedByShardId<? extends ShardContext> contexts,
 DriverContext driverContext,
 int maxPageSize,
 List<SortBuilder<?>> sorts,
 long estimatedPerRowSortSize,
 int limit,
 LuceneSliceQueue sliceQueue,
 boolean needsScore,
 org.elasticsearch.compute.lucene.query.LuceneTopNSourceOperator.PerShardCollectorProvider perShardCollectorProvider)

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

describe

protected void describe(StringBuilder sb)

Specified by:

describe in class LuceneOperator

additionalClose

protected void additionalClose()

Overrides:

additionalClose in class LuceneOperator