Module org.elasticsearch.compute
Package org.elasticsearch.compute.lucene
Class LuceneOperator.Factory
java.lang.Object
org.elasticsearch.compute.lucene.LuceneOperator.Factory
- All Implemented Interfaces:
Describable,Operator.OperatorFactory,SourceOperator.SourceOperatorFactory
- Direct Known Subclasses:
LuceneCountOperator.Factory,LuceneMaxFactory,LuceneMinFactory,LuceneSourceOperator.Factory,LuceneTopNSourceOperator.Factory,TimeSeriesSortedSourceOperatorFactory
- Enclosing class:
LuceneOperator
public abstract static class LuceneOperator.Factory
extends Object
implements SourceOperator.SourceOperatorFactory
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected final DataPartitioningprotected final intprotected final org.apache.lucene.search.ScoreModeprotected final LuceneSliceQueueprotected final int -
Constructor Summary
ConstructorsModifierConstructorDescriptionprotectedFactory(List<? extends ShardContext> contexts, Function<ShardContext, org.apache.lucene.search.Query> queryFunction, DataPartitioning dataPartitioning, int taskConcurrency, int limit, org.apache.lucene.search.ScoreMode scoreMode) Build the factory. -
Method Summary
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.elasticsearch.compute.Describable
describeMethods inherited from interface org.elasticsearch.compute.operator.SourceOperator.SourceOperatorFactory
get
-
Field Details
-
dataPartitioning
-
taskConcurrency
protected final int taskConcurrency -
limit
protected final int limit -
scoreMode
protected final org.apache.lucene.search.ScoreMode scoreMode -
sliceQueue
-
-
Constructor Details
-
Factory
protected Factory(List<? extends ShardContext> contexts, Function<ShardContext, org.apache.lucene.search.Query> queryFunction, DataPartitioning dataPartitioning, int taskConcurrency, int limit, org.apache.lucene.search.ScoreMode scoreMode) Build the factory.- Parameters:
scoreMode- theScoreModepassed toIndexSearcher.createWeight(org.apache.lucene.search.Query, org.apache.lucene.search.ScoreMode, float)
-
-
Method Details
-
taskConcurrency
public final int taskConcurrency() -
limit
public final int limit()
-