Module org.elasticsearch.compute

Package org.elasticsearch.compute.lucene.query

Class LuceneSourceOperator

java.lang.Object

org.elasticsearch.compute.operator.SourceOperator

org.elasticsearch.compute.lucene.query.LuceneOperator

org.elasticsearch.compute.lucene.query.LuceneSourceOperator

All Implemented Interfaces:

Closeable, AutoCloseable, Operator, Releasable

Direct Known Subclasses:

TimeSeriesSourceOperator

public class LuceneSourceOperator
extends LuceneOperator

Source operator that incrementally runs Lucene searches

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	LuceneSourceOperator.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
LuceneSourceOperator(IndexedByShardId<? extends RefCounted> refCounteds, BlockFactory blockFactory, int maxPageSize, LuceneSliceQueue sliceQueue, int limit, Limiter limiter, boolean needsScore, LongSupplier directoryBytesRead)

Method Summary

Modifier and Type	Method	Description
void	additionalClose()
protected void	buildMetadataBlocks(Block[] blocks, int offset, int currentPagePos)
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
protected int	numMetadataBlocks()

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

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

tryPromote

Constructor Details

LuceneSourceOperator

public LuceneSourceOperator(IndexedByShardId<? extends RefCounted> refCounteds,
 BlockFactory blockFactory,
 int maxPageSize,
 LuceneSliceQueue sliceQueue,
 int limit,
 Limiter limiter,
 boolean needsScore,
 LongSupplier directoryBytesRead)

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

numMetadataBlocks

protected int numMetadataBlocks()

buildMetadataBlocks

protected void buildMetadataBlocks(Block[] blocks,
 int offset,
 int currentPagePos)

additionalClose

public void additionalClose()

Overrides:

additionalClose in class LuceneOperator

describe

protected void describe(StringBuilder sb)

Specified by:

describe in class LuceneOperator