Module org.elasticsearch.compute

Package org.elasticsearch.compute.lucene.query

Class LuceneCountOperator

java.lang.Object

org.elasticsearch.compute.operator.SourceOperator

org.elasticsearch.compute.lucene.query.LuceneOperator

org.elasticsearch.compute.lucene.query.LuceneCountOperator

All Implemented Interfaces:

Closeable, AutoCloseable, Operator, Releasable

public class LuceneCountOperator
extends LuceneOperator

Source operator that incrementally counts the results in Lucene searches Returns always one entry that mimics the Count aggregation internal state: 1. the count as a long (0 if no doc is seen) 2. a bool flag (seen) that's always true meaning that the group (all items) always exists

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	LuceneCountOperator.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
LuceneCountOperator(IndexedByShardId<? extends RefCounted> shardRefCounters, DriverContext driverContext, LuceneSliceQueue sliceQueue, List<ElementType> tagTypes, int limit, LongSupplier directoryBytesRead)

Method Summary

Modifier and Type	Method	Description
protected void	describe(StringBuilder sb)
void	finish()	notifies the operator that it won't receive any more input pages
protected 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

additionalClose, 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

LuceneCountOperator

public LuceneCountOperator(IndexedByShardId<? extends RefCounted> shardRefCounters,
 DriverContext driverContext,
 LuceneSliceQueue sliceQueue,
 List<ElementType> tagTypes,
 int limit,
 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

protected Page getCheckedOutput()
                         throws IOException

Specified by:

getCheckedOutput in class LuceneOperator

Throws:

IOException

describe

protected void describe(StringBuilder sb)

Specified by:

describe in class LuceneOperator